From fe3f49232108dd57af244f9545dbc342c19478e6 Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Fri, 29 Dec 2006 23:01:39 +0000 Subject: [PATCH] fixed class cast exception git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491128 13f79535-47bb-0310-9956-ffa450edef68 --- .../activemq/pool/PooledConnectionFactory.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/pool/PooledConnectionFactory.java b/activemq-core/src/main/java/org/apache/activemq/pool/PooledConnectionFactory.java index cdb18e059b..a5916e370c 100644 --- a/activemq-core/src/main/java/org/apache/activemq/pool/PooledConnectionFactory.java +++ b/activemq-core/src/main/java/org/apache/activemq/pool/PooledConnectionFactory.java @@ -139,11 +139,15 @@ public class PooledConnectionFactory implements ConnectionFactory, Service { } } - 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() {