org.opennms.core.logging.Logging.withPrefix()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(8.0k)|赞(0)|评价(0)|浏览(99)

本文整理了Java中org.opennms.core.logging.Logging.withPrefix()方法的一些代码示例,展示了Logging.withPrefix()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Logging.withPrefix()方法的具体详情如下:
包路径:org.opennms.core.logging.Logging
类名称:Logging
方法名:withPrefix

Logging.withPrefix介绍

暂无

代码示例

代码示例来源:origin: OpenNMS/opennms

@Override
  public void run() {
    Logging.withPrefix(LOG4J_CATEGORY, () -> {
      try {
        scheduleExistingInterfaces();
      } finally {
        setSchedulingCompleted(true);
      }
    });
  }
};

代码示例来源:origin: org.opennms.features.collection/org.opennms.features.collection.core

private void log(final String msg, final Object... args) {
  Logging.withPrefix("instrumentation", new Runnable() {
    @Override public void run() {
      LOG.info(msg, args);
    }
  });
  
}

代码示例来源:origin: OpenNMS/opennms

private void log(final String msg, final Object... args) {
  Logging.withPrefix("instrumentation", new Runnable() {
    @Override public void run() {
      LOG.info(msg, args);
    }
  });
  
}

代码示例来源:origin: OpenNMS/opennms

/** {@inheritDoc} */
@Override
public void render(final String reportId, final String location, final ReportFormat format, final OutputStream outputStream) {
  Logging.withPrefix(LOG4J_CATEGORY, new Runnable() {
    @Override public void run() {
      try {
        getReportService(reportId).render(reportId, location, format, outputStream);
      } catch (final ReportException e) {
        LOG.error("Failed to render report", e);
      }
    }
  });
}

代码示例来源:origin: org.opennms.features.reporting/org.opennms.features.reporting.core

/** {@inheritDoc} */
@Override
public void render(final String reportId, final String location, final ReportFormat format, final OutputStream outputStream) {
  Logging.withPrefix(LOG4J_CATEGORY, new Runnable() {
    @Override public void run() {
      try {
        getReportService(reportId).render(reportId, location, format, outputStream);
      } catch (final ReportException e) {
        LOG.error("Failed to render report", e);
      }
    }
  });
}

代码示例来源:origin: org.opennms.features.reporting/org.opennms.features.reporting.availability

/** {@inheritDoc} */
@Override
public void render(final String id, final String location, final ReportFormat format, final OutputStream outputStream) {
  Logging.withPrefix(LOG4J_CATEGORY, new Runnable() {
    @Override public void run() {
      FileInputStream inputStream = null;
      try {
        inputStream = new FileInputStream(location);
        render(id, inputStream, format, outputStream);
      } catch (final FileNotFoundException e) {
        LOG.error("could not open input file", e);
      }
    }
  });
}

代码示例来源:origin: OpenNMS/opennms

/** {@inheritDoc} */
@Override
public void render(final String id, final String location, final ReportFormat format, final OutputStream outputStream) {
  Logging.withPrefix(LOG4J_CATEGORY, new Runnable() {
    @Override public void run() {
      FileInputStream inputStream = null;
      try {
        inputStream = new FileInputStream(location);
        render(id, inputStream, format, outputStream);
      } catch (final FileNotFoundException e) {
        LOG.error("could not open input file", e);
      }
    }
  });
}

代码示例来源:origin: OpenNMS/opennms

@Override
public void sendNowSync(Log eventLog) {
  Objects.requireNonNull(eventLog);
  // Create the runnable and invoke it using the current thread
  // Also set the logging prefix to ensure that the log messages are
  // properly routed to eventd's log file
  Logging.withPrefix(Eventd.LOG4J_CATEGORY, m_eventHandler.createRunnable(eventLog, true));
}

代码示例来源:origin: OpenNMS/opennms

/**
 * Logs the execution time of the @Profile annotated method.
 *
 * @param kind The kind, e.g. "method-execution"
 * @param signature The method signature
 * @param executionTime The execution time in ms.
 */
private static void log(String kind, String signature, long executionTime) {
  Logging.withPrefix("profiler", () -> LoggerFactory.getLogger(ProfilerAspect.class).info("{} {} took {}, raw = {}ms", signature, kind, humanReadable(executionTime), executionTime));
}

代码示例来源:origin: OpenNMS/opennms

/**
 * <p>init</p>
 */
public final void init() {
  
  Logging.withPrefix(getName(), new Runnable() {
    @Override
    public void run() {
      LOG.info("{} initializing.", getName());
      onInit();
      LOG.info("{} initialization complete.", getName());
    }
    
  });
}

代码示例来源:origin: OpenNMS/opennms

public static void reapSession(final Snmp session) {
  if (!s_trackSessions || session == null) return;
  Logging.withPrefix("snmp", () -> {
    assertTrackingInitialized();
    if (!s_sessions.containsKey(session)) {
      LOG.warn("reap: session {} is not being tracked", session, new Exception());
    } else {
      LOG.debug("reap: reaping session {}", s_sessions.get(session));
    }
    s_sessions.remove(session);
  });
}

代码示例来源:origin: org.opennms.core.snmp/org.opennms.core.snmp.implementations.snmp4j

public static void reapSession(final Snmp session) {
  if (!s_trackSessions || session == null) return;
  Logging.withPrefix("snmp", () -> {
    assertTrackingInitialized();
    if (!s_sessions.containsKey(session)) {
      LOG.warn("reap: session {} is not being tracked", session, new Exception());
    } else {
      LOG.debug("reap: reaping session {}", s_sessions.get(session));
    }
    s_sessions.remove(session);
  });
}

代码示例来源:origin: org.opennms.core/org.opennms.core.profiler

/**
 * Logs the execution time of the @Profile annotated method.
 *
 * @param kind The kind, e.g. "method-execution"
 * @param signature The method signature
 * @param executionTime The execution time in ms.
 */
private static void log(String kind, String signature, long executionTime) {
  Logging.withPrefix("profiler", () -> LoggerFactory.getLogger(ProfilerAspect.class).info("{} {} took {}, raw = {}ms", signature, kind, humanReadable(executionTime), executionTime));
}

代码示例来源:origin: org.opennms.features.events/org.opennms.features.events.daemon

@Override
public void sendNowSync(Log eventLog) {
  Objects.requireNonNull(eventLog);
  // Create the runnable and invoke it using the current thread
  // Also set the logging prefix to ensure that the log messages are
  // properly routed to eventd's log file
  Logging.withPrefix(Eventd.LOG4J_CATEGORY, m_eventHandler.createRunnable(eventLog, true));
}

代码示例来源:origin: OpenNMS/opennms

public static void trackSession(final Snmp session) {
  if (!s_trackSessions || session == null) return;
  Logging.withPrefix("snmp", () -> {
    assertTrackingInitialized();
    if (s_sessions.containsKey(session)) {
      LOG.warn("track: session {} is already tracked -- overwriting", s_sessions.get(session));
    }
    final SessionInfo ts = new SessionInfo(session);
    LOG.debug("track: tracking session {}", ts);
    s_sessions.put(session, ts);
  });
}

代码示例来源:origin: OpenNMS/opennms

/**
 * <p>start</p>
 */
@Override
public final synchronized void start() {
  
  Logging.withPrefix(getName(), new Runnable() {
    @Override
    public void run() {
      LOG.info("{} starting.", getName());
      setStatus(STARTING);
      onStart();
      setStatus(RUNNING);
      LOG.info("{} started.", getName());
    }
    
  });
  
}

代码示例来源:origin: OpenNMS/opennms

/**
 * <p>init</p>
 */
@Override
public final void init() {
  Logging.withPrefix(getLoggingPrefix(), new Runnable() {
    @Override
    public void run() {
      LOG.info("{} initializing.", getLoggingPrefix());
      LOG.debug("SPRING: thread.classLoader={}", Thread.currentThread().getContextClassLoader());
      m_context = BeanUtils.getFactory(getSpringContext(), ClassPathXmlApplicationContext.class);
      LOG.debug("SPRING: context.classLoader= {}",  m_context.getClassLoader());
      LOG.info("{} initialization complete.", getLoggingPrefix());
    }
    
  });
}

代码示例来源:origin: OpenNMS/opennms

/**
 * <p>stop</p>
 */
@Override
public final void stop() {
  Logging.withPrefix(getLoggingPrefix(), new Runnable() {
    @Override
    public void run() {
      
      setStatus(Fiber.STOP_PENDING);
      if (m_context != null) {
        m_context.close();
      }
      
      setStatus(Fiber.STOPPED);
    }
    
  });
}

代码示例来源:origin: org.opennms.core.snmp/org.opennms.core.snmp.implementations.snmp4j

public static void trackSession(final Snmp session) {
  if (!s_trackSessions || session == null) return;
  Logging.withPrefix("snmp", () -> {
    assertTrackingInitialized();
    if (s_sessions.containsKey(session)) {
      LOG.warn("track: session {} is already tracked -- overwriting", s_sessions.get(session));
    }
    final SessionInfo ts = new SessionInfo(session);
    LOG.debug("track: tracking session {}", ts);
    s_sessions.put(session, ts);
  });
}

代码示例来源:origin: OpenNMS/opennms

private void createScheduler() {
  Logging.withPrefix(LOG4J_CATEGORY, () -> {
    // Create a scheduler
    try {
      LOG.debug("init: Creating collectd scheduler");
      setScheduler(new LegacyScheduler("Collectd", m_collectdConfigFactory.getCollectdConfig().getThreads()));
    } catch (final RuntimeException e) {
      LOG.error("init: Failed to create collectd scheduler", e);
      throw e;
    }
  });
}

相关文章