Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-26 20:15:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed class cast exception

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491128 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2006-12-29 23:01:39 +00:00
parent 71e44ce436
commit fe3f492321
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/main/java/org/apache/activemq/pool/PooledConnectionFactory.java
View File

@ -141,10 +141,14 @@ public class PooledConnectionFactory implements ConnectionFactory, Service {
public void stop() throws Exception{ public void stop() throws Exception{
for(Iterator iter=cache.values().iterator();iter.hasNext();){ for(Iterator iter=cache.values().iterator();iter.hasNext();){
ConnectionPool connection = (ConnectionPool) iter.next(); LinkedList list=(LinkedList)iter.next();
for(Iterator i=list.iterator();i.hasNext();){
ConnectionPool connection=(ConnectionPool)i.next();
connection.close(); connection.close();
} }
} }
cache.clear();
}
public ObjectPoolFactory getPoolFactory() { public ObjectPoolFactory getPoolFactory() {
if (poolFactory == null) { if (poolFactory == null) {