Sorry it looks like my problem was fairly simple. My producer side looks like this:
Exchange exchange = this.producerTemplate.send(this.endpoint,
ExchangePattern.InOut, new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
exchange.setIn(message);
}
});
return exchange.getIn(MyClass.class);
When what I needed was exchange.getOut(MyClass.class);
Thanks for all of the help though!
