You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2007/06/18 17:37:50 UTC

svn commit: r548381 - /incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/exchange/DestWildExchange.java

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);
         }
     }