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 2019/11/08 21:44:25 UTC

[camel] 02/02: [CAMEL-14156] Avoid NPE with endpoint is null in JmsBinding (#3328)

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 92e3c4f43ec4dc95b41698166d5c1c1c0ff358bb
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Nov 8 22:18:52 2019 +0100

    [CAMEL-14156] Avoid NPE with endpoint is null in JmsBinding (#3328)
---
 .../src/test/java/org/apache/camel/component/jms/JmsBindingTest.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsBindingTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsBindingTest.java
index 1c29e26..9562b8b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsBindingTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsBindingTest.java
@@ -23,8 +23,9 @@ import java.util.Date;
 
 import org.apache.activemq.command.ActiveMQBlobMessage;
 import org.apache.activemq.command.ActiveMQTextMessage;
+import org.apache.camel.Exchange;
 import org.apache.camel.impl.DefaultCamelContext;
-import org.apache.camel.impl.DefaultExchange;
+
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -62,7 +63,7 @@ public class JmsBindingTest {
         ActiveMQTextMessage message = new ActiveMQTextMessage();
         message.setText("test");
         DefaultCamelContext camelContext = new DefaultCamelContext();
-        DefaultExchange exchange = new DefaultExchange(camelContext);
+        Exchange exchange = camelContext.getEndpoint("jms:queue:foo").createExchange();
         exchange.getIn().setBody("test");
         exchange.getIn().setHeader("JMSCorrelationID", null);
         testBindingWithoutEndpoint.appendJmsProperties(message, exchange);