You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2020/02/25 09:04:49 UTC
[camel] 01/02: CAMEL-14020: Fixed test
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 <cl...@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");