private void send()

in collector/camel/src/main/java/org/apache/karaf/decanter/collector/camel/DecanterInterceptStrategy.java [50:78]


    private void send(Exchange exchange) {
        HashMap<String, Object> data = new HashMap<>();
        data.put("type", "camelTracer");
        data.put("karafName", System.getProperty("karaf.name"));
        try {
            data.put("hostAddress", InetAddress.getLocalHost().getHostAddress());
            data.put("hostName", InetAddress.getLocalHost().getHostName());
        } catch (Exception e) {
            // no-op
        }
        data.put("timestamp", System.currentTimeMillis());
        new DefaultExchangeExtender().extend(data, exchange);
        for (String property : exchange.getProperties().keySet()) {
            if (property.startsWith("decanter.")) {
                data.put(property.substring("decanter.".length()), exchange.getProperties().get(property));
            }
        }
        dextender.extend(data, exchange);
        if (extender != null)  {
            extender.extend(data, exchange);
        }
        for (String header : exchange.getIn().getHeaders().keySet()) {
            if (header.startsWith("decanter.")) {
                data.put(header.substring("decanter.".length()), exchange.getIn().getHeader(header));
            }
        }
        Event event = new Event(topic, data);
        dispatcher.postEvent(event);
    }