This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit abf5b1f68d298e65782f250f28406b11386f114c
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue Feb 25 09:40:31 2020 +0100

    CAMEL-14020: Fixed test
---
 .../java/org/apache/camel/component/quickfixj/QuickfixjConsumer.java    | 2 +-
 .../org/apache/camel/component/quickfixj/QuickfixjProducerTest.java     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjConsumer.java
 
b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjConsumer.java
index 5bac9a0..1703729 100644
--- 
a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjConsumer.java
+++ 
b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjConsumer.java
@@ -55,7 +55,7 @@ public class QuickfixjConsumer extends DefaultConsumer {
     }
 
     private void sendOutMessage(Exchange exchange) throws QFJException {
-        Message camelMessage = exchange.getOut();
+        Message camelMessage = exchange.getMessage();
         quickfix.Message quickfixjMessage = 
camelMessage.getBody(quickfix.Message.class);
 
         LOG.debug("Sending FIX message reply: {}", quickfixjMessage);
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 aadd05c..de0399c 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
@@ -125,7 +125,7 @@ public class QuickfixjProducerTest {
             1000L, Long.class)).thenReturn(5000L);
                 
         org.apache.camel.Message mockOutboundCamelMessage = 
Mockito.mock(org.apache.camel.Message.class);
-        
Mockito.when(mockExchange.getMessage()).thenReturn(mockOutboundCamelMessage);
+        
Mockito.when(mockExchange.getOut()).thenReturn(mockOutboundCamelMessage);
         
         final Message outboundFixMessage = new Email();
         outboundFixMessage.getHeader().setString(SenderCompID.FIELD, "TARGET");

Reply via email to