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/8f5b61a0 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/8f5b61a0 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/8f5b61a0 Branch: refs/heads/camel-2.12.x Commit: 8f5b61a00050c4adc73c1cf4bda354dba6e59d7c Parents: 709595f 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:02 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/8f5b61a0/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(
