ensure the noLocal flag is passed through to durable subscriber
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/b8d40c2c Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/b8d40c2c Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/b8d40c2c Branch: refs/heads/master Commit: b8d40c2c15f1dea09d29717befc0e43ce9266413 Parents: c15320b Author: Robert Gemmell <rob...@apache.org> Authored: Wed Jan 14 15:06:11 2015 +0000 Committer: Robert Gemmell <rob...@apache.org> Committed: Wed Jan 14 15:06:11 2015 +0000 ---------------------------------------------------------------------- qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/b8d40c2c/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java index 92410dc..f724f06 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java @@ -420,7 +420,7 @@ public class JmsSession implements Session, QueueSession, TopicSession, JmsMessa checkClientIDWasSetExplicitly(); messageSelector = checkSelector(messageSelector); JmsDestination dest = JmsMessageTransformation.transformDestination(connection, topic); - JmsTopicSubscriber result = new JmsDurableTopicSubscriber(getNextConsumerId(), this, dest, name, false, messageSelector); + JmsTopicSubscriber result = new JmsDurableTopicSubscriber(getNextConsumerId(), this, dest, name, noLocal, messageSelector); result.init(); return result; } --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
