Author: clebert.suconic(a)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);
}
Show replies by date