Author: ritchiem
Date: Mon Jun 18 08:37:41 2007
New Revision: 548381
URL: http://svn.apache.org/viewvc?view=rev&rev=548381
Log:
QPID-525 Memory leak in DestWildExchange. Used routing key in remove rather
than empty queue
Modified:
incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/exchange/DestWildExchange.java
Modified:
incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/exchange/DestWildExchange.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/exchange/DestWildExchange.java?view=diff&rev=548381&r1=548380&r2=548381
==============================================================================
---
incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/exchange/DestWildExchange.java
(original)
+++
incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/exchange/DestWildExchange.java
Mon Jun 18 08:37:41 2007
@@ -222,7 +222,6 @@
{
_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 @@
}
if (queues.isEmpty())
{
- _routingKey2queues.remove(queues);
+ _routingKey2queues.remove(routingKey);
}
}