void onMessageExchange(MessageExhange exchange) { if (exchange.getStatus() == ExchangeStatus.ACTIVE) { // copy content Source content = exchange.getMessage("in").getContent(); content = transform(content); exchange.getMessage("out").setContent(content); Map headers = exchange.getMessage("in").getProperty(JbiConstants.SOAP_HEADERS); // do whatever you want exchange.getMessage("out").setProperty(headers); channel.send(exchange); }