Author: jstrachan
Date: Mon Aug 21 01:40:08 2006
New Revision: 433198
URL: http://svn.apache.org/viewvc?rev=433198&view=rev
Log:
remove memory leak of consumers & browsers
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/PooledSession.java
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/PooledSession.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/PooledSession.java?rev=433198&r1=433197&r2=433198&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/PooledSession.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/PooledSession.java
Mon Aug 21 01:40:08 2006
@@ -87,11 +87,13 @@
MessageConsumer consumer = (MessageConsumer) iter.next();
consumer.close();
}
+ consumers.clear();
for (Iterator iter = browsers.iterator(); iter.hasNext();) {
QueueBrowser browser = (QueueBrowser) iter.next();
browser.close();
}
+ browsers.clear();
// maybe do a rollback?
if (transactional) {
