summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2007-06-18 15:37:41 +0000
committerMartin Ritchie <ritchiem@apache.org>2007-06-18 15:37:41 +0000
commit5abd0575d13b26baf5778e7aac3c425a9a4fa143 (patch)
treea1e880fe4022e2cdb25cb43f12196bda51abcd0e
parent5674547b6246d3370409aec281f915ecb0bcc109 (diff)
downloadqpid-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.java3
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);
}
}