CAMEL-7287: Fixed camel-sjms to use NoLocal as false which is the default in JMS spec. This can prevent camel-sjms from connecting to durable topics.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5573e19a Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5573e19a Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5573e19a Branch: refs/heads/camel-2.11.x Commit: 5573e19a67677cac643dbf0fb1cd2e89d58caa93 Parents: 90d9611 Author: Claus Ibsen <davscl...@apache.org> Authored: Thu Mar 13 10:12:43 2014 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Thu Mar 13 10:13:25 2014 +0100 ---------------------------------------------------------------------- .../apache/camel/component/sjms/jms/JmsObjectFactory.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/5573e19a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/jms/JmsObjectFactory.java ---------------------------------------------------------------------- diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/jms/JmsObjectFactory.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/jms/JmsObjectFactory.java index 93040d5..adc87cd 100644 --- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/jms/JmsObjectFactory.java +++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/jms/JmsObjectFactory.java @@ -61,15 +61,15 @@ public final class JmsObjectFactory { } public static MessageConsumer createQueueConsumer(Session session, String destinationName) throws Exception { - return createMessageConsumer(session, destinationName, null, false, null, true); + return createMessageConsumer(session, destinationName, null, false, null); } public static MessageConsumer createQueueConsumer(Session session, String destinationName, String messageSelector) throws Exception { - return createMessageConsumer(session, destinationName, messageSelector, false, null, true); + return createMessageConsumer(session, destinationName, messageSelector, false, null); } public static MessageConsumer createTopicConsumer(Session session, String destinationName, String messageSelector) throws Exception { - return createMessageConsumer(session, destinationName, messageSelector, true, null, true); + return createMessageConsumer(session, destinationName, messageSelector, true, null); } public static MessageConsumer createTemporaryMessageConsumer( @@ -88,7 +88,8 @@ public final class JmsObjectFactory { String messageSelector, boolean topic, String durableSubscriptionId) throws Exception { - return createMessageConsumer(session, destinationName, messageSelector, topic, durableSubscriptionId, true); + // noLocal is default false accordingly to JMS spec + return createMessageConsumer(session, destinationName, messageSelector, topic, durableSubscriptionId, false); } public static MessageConsumer createMessageConsumer(
