in collector/log/src/main/java/org/apache/karaf/decanter/collector/log/LogCollector.java [96:133]
protected void appendInternal(PaxLoggingEvent event) throws Exception {
if (includedCategories != null && !filterCategory(event.getLoggerName(), includedCategories)) {
LOGGER.debug("{} logger is not in the included list", event.getLoggerName());
return;
}
if (filterCategory(event.getLoggerName(), excludedCategories)) {
LOGGER.debug("{} logger is ignored by the log collector", event.getLoggerName());
return;
}
Map<String, Object> data = new HashMap<>();
data.put("type", "log");
data.put("timestamp", event.getTimeStamp());
data.put("loggerClass", event.getFQNOfLoggerClass());
data.put("loggerName", event.getLoggerName());
data.put("threadName", event.getThreadName());
data.put("message", event.getMessage());
data.put("level", (event.getLevel() != null) ? event.getLevel().toString() : "default");
data.put("renderedMessage", event.getRenderedMessage());
data.put("MDC", event.getProperties());
if (locationDisabledCategories == null || !filterCategory(event.getLoggerName(), locationDisabledCategories)) {
putLocation(data, event.getLocationInformation());
}
String[] throwableAr = event.getThrowableStrRep();
if (throwableAr != null) {
data.put("throwable", join(throwableAr));
}
PropertiesPreparator.prepare(data, properties);
String loggerName = event.getLoggerName();
if (loggerName == null || loggerName.isEmpty()) {
loggerName = "default";
}
String topic = (properties.get(EventConstants.EVENT_TOPIC) != null) ? (String) properties.get(EventConstants.EVENT_TOPIC) : "decanter/collect/log/";
this.dispatcher.postEvent(new Event(topic + cleanLoggerName(loggerName), data));
}