You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2006/12/30 00:01:40 UTC
svn commit: r491128 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/PooledConnectionFactory.java
Author: rajdavies
Date: Fri Dec 29 15:01:39 2006
New Revision: 491128
URL: http://svn.apache.org/viewvc?view=rev&rev=491128
Log:
fixed class cast exception
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/PooledConnectionFactory.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/PooledConnectionFactory.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/PooledConnectionFactory.java?view=diff&rev=491128&r1=491127&r2=491128
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/PooledConnectionFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/PooledConnectionFactory.java Fri Dec 29 15:01:39 2006
@@ -139,11 +139,15 @@
}
}
- public void stop() throws Exception {
- for (Iterator iter = cache.values().iterator(); iter.hasNext();) {
- ConnectionPool connection = (ConnectionPool) iter.next();
- connection.close();
+ public void stop() throws Exception{
+ for(Iterator iter=cache.values().iterator();iter.hasNext();){
+ LinkedList list=(LinkedList)iter.next();
+ for(Iterator i=list.iterator();i.hasNext();){
+ ConnectionPool connection=(ConnectionPool)i.next();
+ connection.close();
+ }
}
+ cache.clear();
}
public ObjectPoolFactory getPoolFactory() {