Preserve headers in QuickfixjProducer.process() Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f294ba21 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f294ba21 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f294ba21
Branch: refs/heads/master Commit: f294ba21e9c039edbea2e593cf44ac73d81d1bbe Parents: e6f1bc4 Author: Grzegorz Grzybek <ggrzy...@redhat.com> Authored: Tue Feb 11 11:15:03 2014 +0100 Committer: Grzegorz Grzybek <ggrzy...@redhat.com> Committed: Tue Feb 11 11:15:03 2014 +0100 ---------------------------------------------------------------------- .../org/apache/camel/component/quickfixj/QuickfixjProducer.java | 1 + .../org/apache/camel/component/quickfixj/QuickfixjProducerTest.java | 1 + 2 files changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/f294ba21/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjProducer.java b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjProducer.java index ff262c0..9e1dbf0 100644 --- a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjProducer.java +++ b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjProducer.java @@ -77,6 +77,7 @@ public class QuickfixjProducer extends DefaultProducer { if (callable != null) { Message reply = callable.call(); + exchange.getOut().getHeaders().putAll(camelMessage.getHeaders()); exchange.getOut().setBody(reply); } } http://git-wip-us.apache.org/repos/asf/camel/blob/f294ba21/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjProducerTest.java b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjProducerTest.java index 498f6ff..be6f341 100644 --- a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjProducerTest.java +++ b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjProducerTest.java @@ -153,6 +153,7 @@ public class QuickfixjProducerTest { Mockito.verify(mockExchange, Mockito.never()).setException(Matchers.isA(IllegalStateException.class)); Mockito.verify(mockSession).send(inboundFixMessage); + Mockito.verify(mockOutboundCamelMessage).getHeaders(); Mockito.verify(mockOutboundCamelMessage).setBody(outboundFixMessage); }
