本文整理了Java中org.opennms.core.logging.Logging.withPrefix()
方法的一些代码示例,展示了Logging.withPrefix()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Logging.withPrefix()
方法的具体详情如下:
包路径:org.opennms.core.logging.Logging
类名称: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;
}
});
}
内容来源于网络,如有侵权,请联系作者删除!