Repository: cxf Updated Branches: refs/heads/jms-exception-handling 42c1afb9a -> 822429bce (forced update)
[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/jms-exception-handling 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) {
