Repository: camel Updated Branches: refs/heads/camel-2.11.x 90d9611c9 -> 5573e19a6 refs/heads/camel-2.12.x 709595fcc -> 8f5b61a00 refs/heads/master b7df19acc -> 4be7f3630
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/4be7f363 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/4be7f363 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/4be7f363 Branch: refs/heads/master Commit: 4be7f3630491ebbb716abb50233b7b453c39eb53 Parents: b7df19a 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:12:43 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/4be7f363/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 3ed3a24..382ed68 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(
