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