From b26cf4a8ebfb718a3e314e1f696456cf2addce23 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Mon, 10 Feb 2014 09:15:10 +0000 Subject: QPID-5504 : Re-enable the use of no-local on consumers to queues in 0-8 protocol git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1566535 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/qpid/server/filter/FilterSupport.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'qpid/java/broker-core') diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/filter/FilterSupport.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/filter/FilterSupport.java index b50424868a..efefec58fd 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/filter/FilterSupport.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/filter/FilterSupport.java @@ -30,6 +30,7 @@ import org.apache.qpid.common.AMQPFilterTypes; import org.apache.qpid.filter.SelectorParsingException; import org.apache.qpid.filter.selector.ParseException; import org.apache.qpid.filter.selector.TokenMgrError; +import org.apache.qpid.server.message.MessageSource; import org.apache.qpid.server.protocol.AMQSessionModel; import org.apache.qpid.server.queue.AMQQueue; @@ -118,11 +119,11 @@ public class FilterSupport } } - static final class NoLocalFilter implements MessageFilter + public static final class NoLocalFilter implements MessageFilter { - private final AMQQueue _queue; + private final MessageSource _queue; - public NoLocalFilter(AMQQueue queue) + public NoLocalFilter(MessageSource queue) { _queue = queue; } -- cgit v1.2.1