From 5abd0575d13b26baf5778e7aac3c425a9a4fa143 Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Mon, 18 Jun 2007 15:37:41 +0000 Subject: 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 --- .../main/java/org/apache/qpid/server/exchange/DestWildExchange.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) (limited to 'java/broker/src') 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); } } -- cgit v1.2.1