You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by cs...@apache.org on 2017/04/20 13:17:41 UTC
cxf git commit: [CXF-6441] Set pubSubNoLocal in JMSDestination
Repository: cxf
Updated Branches:
refs/heads/master b43dfb972 -> 1f9cbe367
[CXF-6441] Set pubSubNoLocal in JMSDestination
Project: http://git-wip-us.apache.org/repos/asf/cxf/repo
Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/1f9cbe36
Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/1f9cbe36
Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/1f9cbe36
Branch: refs/heads/master
Commit: 1f9cbe3678c1984fd2fd57e26fdd5626841c32e9
Parents: b43dfb9
Author: Christian Schneider <ch...@die-schneider.net>
Authored: Thu Apr 20 15:15:00 2017 +0200
Committer: Christian Schneider <ch...@die-schneider.net>
Committed: Thu Apr 20 15:15:00 2017 +0200
----------------------------------------------------------------------
.../src/main/java/org/apache/cxf/transport/jms/JMSDestination.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cxf/blob/1f9cbe36/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSDestination.java
----------------------------------------------------------------------
diff --git a/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSDestination.java b/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSDestination.java
index 2d7f4db..8ec23cd 100644
--- a/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSDestination.java
+++ b/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSDestination.java
@@ -136,6 +136,7 @@ public class JMSDestination extends AbstractMultiplexDestination implements Mess
container.setMessageSelector(jmsConfig.getMessageSelector());
container.setTransacted(jmsConfig.isSessionTransacted());
container.setDurableSubscriptionName(jmsConfig.getDurableSubscriptionName());
+ container.setPubSubNoLocal(jmsConfig.isPubSubNoLocal());
Object executor = bus.getProperty(JMSFactory.JMS_DESTINATION_EXECUTOR);
if (executor instanceof Executor) {