[hornetq-commits] JBoss hornetq SVN: r11258 - branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/management/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-08-31 08:54:38 -0400 (Wed, 31 Aug 2011)
New Revision: 11258

Modified:
   branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/management/impl/ManagementServiceImpl.java
Log:
fixing thread leakage

Modified: branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/management/impl/ManagementServiceImpl.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/management/impl/ManagementServiceImpl.java	2011-08-31 04:46:11 UTC (rev 11257)
+++ branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/management/impl/ManagementServiceImpl.java	2011-08-31 12:54:38 UTC (rev 11258)
@@ -304,11 +304,14 @@
    public void unregisterAcceptors()
    {
       List<String> acceptors = new ArrayList<String>();
-      for (String resourceName : registry.keySet())
+      synchronized (this)
       {
-         if (resourceName.startsWith(ResourceNames.CORE_ACCEPTOR))
+         for (String resourceName : registry.keySet())
          {
-            acceptors.add(resourceName);
+            if (resourceName.startsWith(ResourceNames.CORE_ACCEPTOR))
+            {
+               acceptors.add(resourceName);
+            }
          }
       }
 
@@ -508,7 +511,7 @@
       registry.put(resourceName, managedResource);
    }
 
-   public void unregisterFromRegistry(final String resourceName)
+   public synchronized void unregisterFromRegistry(final String resourceName)
    {
       registry.remove(resourceName);
    }