protected void appendInternal()

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));
    }