diff options
| author | Keith Wall <kwall@apache.org> | 2011-11-28 09:19:15 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2011-11-28 09:19:15 +0000 |
| commit | 4ee4c8776c48bdc0a2bd1c2e34e71bf3a63e33cd (patch) | |
| tree | 8f5a5c8e728615f6442f9e317518817f15a3ee74 /java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java | |
| parent | 907330f70818a437f7a0723743ab98b355d80d67 (diff) | |
| download | qpid-python-4ee4c8776c48bdc0a2bd1c2e34e71bf3a63e33cd.tar.gz | |
QPID-3642,QPID-3643: Add Dead Letter Queue functionality for 0-8/0-9/0-9-1 paths, fixes isBound methods on FanoutExchange
Applied patch from Keith Wall <keith.wall@gmail.com>, Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1207029 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java index bd75f7bc51..76f86ea1b4 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java +++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java @@ -117,7 +117,7 @@ public class FanoutExchange extends AbstractExchange public boolean isBound(AMQShortString routingKey, AMQQueue queue) { - return _queues.contains(queue); + return _queues.containsKey(queue); } public boolean isBound(AMQShortString routingKey) @@ -129,7 +129,7 @@ public class FanoutExchange extends AbstractExchange public boolean isBound(AMQQueue queue) { - return _queues.contains(queue); + return _queues.containsKey(queue); } public boolean hasBindings() |