in collector/camel/src/main/java/org/apache/karaf/decanter/collector/camel/DefaultExchangeExtender.java [38:68]
public void extend(Map<String, Object> data, Exchange exchange) {
data.put("fromEndpointUri", exchange.getFromEndpoint() != null ? exchange.getFromEndpoint().getEndpointUri() : null);
if (includeHistory) {
setHistory(data, exchange);
}
data.put("exchangeId", exchange.getExchangeId());
data.put("routeId", exchange.getFromRouteId());
data.put("camelContextName", exchange.getContext().getName());
data.put("shortExchangeId", extractShortExchangeId(exchange));
data.put("exchangePattern", exchange.getPattern().toString());
if (includeProperties) {
data.put("properties", exchange.getProperties());
}
if (includeHeaders) {
data.put("inHeaders", exchange.getIn().getHeaders());
}
if (includeBody) {
data.put("inBody", extractBodyAsString(exchange.getIn()));
}
data.put("inBodyType", getBodyTypeName(exchange.getIn()));
if (exchange.hasOut()) {
if (includeHeaders) {
data.put("outHeaders", exchange.getOut().getHeaders());
}
if (includeBody) {
data.put("outBody", extractBodyAsString(exchange.getOut()));
}
data.put("outBodyType", getBodyTypeName(exchange.getOut()));
}
data.put("causedByException", extractCausedByException(exchange));
}