public void connect() {
close();
// JMXServiceURL jmxUrl = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://" + _HostPortString + "/jmxrmi");
JmxConnectionDescriptor descriptor = getDescriptor();
JMXServiceURL jmxUrl = descriptor.getJmxServiceUrl();
String userName = descriptor.getUserName();
String password = descriptor.getPassword();
Map<String, String[]> env = null;
if (userName != null) {
env = new HashMap<String, String[]>();
env.put(JMXConnector.CREDENTIALS, new String[] { userName, password });
}
try {
_JMXConnector = JMXConnectorFactory.connect(jmxUrl, env);
_MBeanServerConnection = _JMXConnector.getMBeanServerConnection();
_Connected = true;
addConnectionListener();
addMBeanServerDelegateListener();
// System.out.println("JMX connection opened");
fireConnectionStateChanged(null);
}
catch (IOException e) {
}
}
JmxConnection.java 文件源码
java
阅读 27
收藏 0
点赞 0
评论 0
项目:eZooKeeper
作者:
评论列表
文章目录