protected void process(MessageExchange exchange, NormalizedMessage message) throws Exception {
protected void process(MessageExchange exchange) throws Exception {
        protected void process(MessageExchange exchange, NormalizedMessage message) throws Exception {            if (exchange.getStatus() != ExchangeStatus.ACTIVE) {                return;            }            try {                store.store(exchange.getExchangeId(), exchange);            } catch (Exception e) {                throw new MessagingException(e);            }            if (rollback) {                try {                    tm.setRollbackOnly();                } catch (Exception e) {                    throw new MessagingException(e);                }            }            if (exchange instanceof InOnly) {                exchange.setStatus(ExchangeStatus.DONE);                getDeliveryChannel().send(exchange);            } else {                NormalizedMessage msg = exchange.createMessage();                msg.setContent(exchange.getMessage("in").getContent());                exchange.setMessage(msg, "out");                if (sync) {                    getDeliveryChannel().sendSync(exchange);                } else {                    getDeliveryChannel().send(exchange);                }            }        }