You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2013/09/03 13:49:44 UTC
[3/4] git commit: CAMEL-6695: ManagementAgent should use a thread
safe map for housekeeping of registered mbeans.
CAMEL-6695: ManagementAgent should use a thread safe map for housekeeping of registered mbeans.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/4a4f6930
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/4a4f6930
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/4a4f6930
Branch: refs/heads/camel-2.11.x
Commit: 4a4f6930bb6e6bc1a7bd38d0f16ec4ad1037c249
Parents: b3bc9bc
Author: Claus Ibsen <da...@apache.org>
Authored: Tue Sep 3 13:48:19 2013 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Tue Sep 3 13:48:57 2013 +0200
----------------------------------------------------------------------
.../camel/management/DefaultManagementAgent.java | 16 +++++++++-------
1 file changed, 9 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/4a4f6930/camel-core/src/main/java/org/apache/camel/management/DefaultManagementAgent.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/management/DefaultManagementAgent.java b/camel-core/src/main/java/org/apache/camel/management/DefaultManagementAgent.java
index ad44b11..78fc97a 100644
--- a/camel-core/src/main/java/org/apache/camel/management/DefaultManagementAgent.java
+++ b/camel-core/src/main/java/org/apache/camel/management/DefaultManagementAgent.java
@@ -25,9 +25,9 @@ import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.rmi.server.UnicastRemoteObject;
-import java.util.HashMap;
import java.util.List;
-import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
import javax.management.JMException;
import javax.management.MBeanServer;
import javax.management.MBeanServerFactory;
@@ -62,7 +62,7 @@ public class DefaultManagementAgent extends ServiceSupport implements Management
private CamelContext camelContext;
private MBeanServer server;
// need a name -> actual name mapping as some servers changes the names (such as WebSphere)
- private final Map<ObjectName, ObjectName> mbeansRegistered = new HashMap<ObjectName, ObjectName>();
+ private final ConcurrentMap<ObjectName, ObjectName> mbeansRegistered = new ConcurrentHashMap<ObjectName, ObjectName>();
private JMXConnectorServer cs;
private Registry registry;
@@ -238,15 +238,17 @@ public class DefaultManagementAgent extends ServiceSupport implements Management
public void unregister(ObjectName name) throws JMException {
if (isRegistered(name)) {
- server.unregisterMBean(mbeansRegistered.get(name));
+ ObjectName on = mbeansRegistered.remove(name);
+ server.unregisterMBean(on);
LOG.debug("Unregistered MBean with ObjectName: {}", name);
+ } else {
+ mbeansRegistered.remove(name);
}
- mbeansRegistered.remove(name);
}
public boolean isRegistered(ObjectName name) {
- return (mbeansRegistered.containsKey(name)
- && server.isRegistered(mbeansRegistered.get(name)))
+ ObjectName on = mbeansRegistered.get(name);
+ return (on != null && server.isRegistered(on))
|| server.isRegistered(name);
}