This commit is contained in:
Yako
2015-02-06 17:02:22 +08:00
parent 1ed2ff478c
commit 770504cce3
2 changed files with 7 additions and 18 deletions
@@ -1394,12 +1394,10 @@ public class DruidDataSource extends DruidAbstractDataSource
public Object run() {
ObjectName objectName = DruidDataSourceStatManager.addDataSource(DruidDataSource.this,
DruidDataSource.this.name);
if (objectName != null) {
DruidDataSource.this.setObjectName(objectName);
DruidDataSource.this.mbeanRegistered = true;
}
DruidDataSource.this.setObjectName(objectName);
DruidDataSource.this.mbeanRegistered = true;
return null;
}
});
@@ -127,22 +127,13 @@ public class DruidDataSourceStatManager implements DruidDataSourceStatManagerMBe
}
public synchronized static ObjectName addDataSource(Object dataSource, String name) {
if (dataSource == null || name == null) {
return null;
}
final IdentityHashMap<Object, ObjectName> instances = getInstances();
synchronized (instances) {
MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();
if (mbeanServer == null) {
return null;
}
if (instances.size() == 0) {
try {
ObjectName objectName = new ObjectName(MBEAN_NAME);
if (!mbeanServer.isRegistered(objectName)) {
mbeanServer.registerMBean(instance, objectName);
@@ -150,7 +141,7 @@ public class DruidDataSourceStatManager implements DruidDataSourceStatManagerMBe
} catch (JMException ex) {
LOG.error("register mbean error", ex);
}
DruidStatService.registerMBean();
}