diff options
author | Martin Ritchie <ritchiem@apache.org> | 2007-06-18 15:37:41 +0000 |
---|---|---|
committer | Martin Ritchie <ritchiem@apache.org> | 2007-06-18 15:37:41 +0000 |
commit | 5abd0575d13b26baf5778e7aac3c425a9a4fa143 (patch) | |
tree | a1e880fe4022e2cdb25cb43f12196bda51abcd0e | |
parent | 5674547b6246d3370409aec281f915ecb0bcc109 (diff) | |
download | qpid-python-5abd0575d13b26baf5778e7aac3c425a9a4fa143.tar.gz |
QPID-525 Memory leak in DestWildExchange. Used routing key in remove rather than empty queue
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@548381 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/exchange/DestWildExchange.java | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/exchange/DestWildExchange.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/DestWildExchange.java index e9c5b0024c..0202ccb762 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/exchange/DestWildExchange.java +++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/DestWildExchange.java @@ -222,7 +222,6 @@ public class DestWildExchange extends AbstractExchange { _logger.warn("No queues found for routing key " + routingKey); _logger.warn("Routing map contains: " + _routingKey2queues); - //todo Check for valid topic - mritchie return; } } @@ -288,7 +287,7 @@ public class DestWildExchange extends AbstractExchange } if (queues.isEmpty()) { - _routingKey2queues.remove(queues); + _routingKey2queues.remove(routingKey); } } |