You are viewing a plain text version of this content. The canonical link for it is here.
Posted to axis-cvs@ws.apache.org by di...@apache.org on 2005/12/08 22:54:24 UTC

svn commit: r355231 - /webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSConnectorManager.java

Author: dims
Date: Thu Dec  8 13:54:22 2005
New Revision: 355231

URL: http://svn.apache.org/viewcvs?rev=355231&view=rev
Log:
prevent exception during shutdown


Modified:
    webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSConnectorManager.java

Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSConnectorManager.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSConnectorManager.java?rev=355231&r1=355230&r2=355231&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSConnectorManager.java (original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSConnectorManager.java Thu Dec  8 13:54:22 2005
@@ -123,10 +123,10 @@
             while (iter.hasNext()) {
                 // close all connectors in the vendor pool
                 ShareableObjectPool pool = (ShareableObjectPool) iter.next();
-                synchronized (pool) {
-                    java.util.Iterator connectors = pool.getElements().iterator();
-                    while (connectors.hasNext()) {
-                        JMSConnector conn = (JMSConnector) connectors.next();
+                synchronized (pool) {              
+                    Object[] elements = pool.getElements().toArray();
+                    for (int i=0;i<elements.length;i++) {
+                        JMSConnector conn = (JMSConnector) elements[i];
                         try {
                             // shutdown automatically decrements the ref count of a connector before closing it
                             // call reserve() to simulate the checkout