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 2014/03/13 10:10:54 UTC
[3/3] git commit: 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.
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 <da...@apache.org>
Authored: Thu Mar 13 10:12:43 2014 +0100
Committer: Claus Ibsen <da...@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(