Package javax.management.remote

Examples of javax.management.remote.JMXConnector.connect()

77
78
79
80
81
82
83
84
85
86
87
    private void resetLilyState() throws Exception {
        JMXServiceURL url = new JMXServiceURL("service:jmx:rmi://localhost:10102/jndi/rmi://localhost:10102/jmxrmi");

        JMXConnector connector = JMXConnectorFactory.connect(url);
        connector.connect();

        ObjectName lilyLauncher = new ObjectName("LilyLauncher:name=Launcher");
        connector.getMBeanServerConnection().invoke(lilyLauncher, "resetLilyState", new Object[0], new String[0]);
        connector.close();
    }
View Full Code Here
141
142
143
144
145
146
147
148
149
150
151
        Exception exception = null;
    for (JMXServiceURL url : jmxUrls) {
      try {
        JMXConnector connector = JMXConnectorFactory.connect(url, env);
        connector.connect();
        MBeanServerConnection connection = connector
            .getMBeanServerConnection();

        Set<ObjectName> brokers = findBrokers(connection);
        if (brokers.size() > 0) {
View Full Code Here
143
144
145
146
147
148
149
150
151
152
153
        Exception exception = null;
    for (JMXServiceURL url : jmxUrls) {
      try {
        JMXConnector connector = JMXConnectorFactory.connect(url, env);
        connector.connect();
        MBeanServerConnection connection = connector
            .getMBeanServerConnection();

        Set<ObjectName> brokers = findBrokers(connection);
        if (brokers.size() > 0) {
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
    cluster.waitUntilShutDown();

    JMXConnector connector = JMXConnectorFactory.newJMXConnector(
      JMXListener.buildJMXServiceURL(connectorPort,connectorPort), null);
    expectedEx.expect(IOException.class);
    connector.connect();

  }


}
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
  }

    public void testMoveMessages() throws Exception {
        JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:1199/jmxrmi");
        JMXConnector connector = JMXConnectorFactory.connect(url, null);
        connector.connect();
        MBeanServerConnection connection = connector.getMBeanServerConnection();
        ObjectName name = new ObjectName("org.apache.activemq:BrokerName=localhost,Type=Queue,Destination=TEST.Q");
        QueueViewMBean queueMbean = (QueueViewMBean) MBeanServerInvocationHandler.newProxyInstance(connection, name, QueueViewMBean.class, true);
        String msgId = queueMbean.sendTextMessage("test", "system", "manager");
        queueMbean.moveMessageTo(msgId, "TEST1.Q");
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
   
   
    public void testBrowseExpiredMessages() throws Exception {
        JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:1199/jmxrmi");
        JMXConnector connector = JMXConnectorFactory.connect(url, null);
        connector.connect();
        MBeanServerConnection connection = connector.getMBeanServerConnection();
        ObjectName name = new ObjectName("org.apache.activemq:BrokerName=localhost,Type=Queue,Destination=TEST.Q");
        QueueViewMBean queueMbean = (QueueViewMBean) MBeanServerInvocationHandler.newProxyInstance(connection, name, QueueViewMBean.class, true);
        HashMap<String, String> headers = new HashMap<String, String>();
        headers.put("JMSExpiration", Long.toString(System.currentTimeMillis() + 2000));
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
    cluster.waitUntilShutDown();

    JMXConnector connector = JMXConnectorFactory.newJMXConnector(
      JMXListener.buildJMXServiceURL(connectorPort,connectorPort), null);
    expectedEx.expect(IOException.class);
    connector.connect();

  }


}
View Full Code Here
1140
1141
1142
1143
1144
1145
1146
1147
1148
1149
1150
        System.out.println("got jmx url: " + jmxUrl);

        // connect to jmx
        JMXConnector connector = JMXConnectorFactory.connect(jmxUrl);

        connector.connect();

        MBeanServerConnection mbeanServer = connector.getMBeanServerConnection();

        // look for all beans in the d2 name space
        Set<ObjectInstance> objectInstances =
View Full Code Here
32
33
34
35
36
37
38
39
40
41
42
        JMXServiceURL url = agent.getUrl();

        assertEquals(url.toString(), format("service:jmx:rmi:///jndi/rmi://%s:%s/jmxrmi", address.getHostText(), address.getPort()));

        JMXConnector connector = JMXConnectorFactory.connect(url);
        connector.connect();

        MBeanServerConnection connection = connector.getMBeanServerConnection();
        assertTrue(connection.getMBeanCount() > 0);
    }
View Full Code Here
31
32
33
34
35
36
37
38
39
40
41
        JMXServiceURL url = agent.getUrl();

        assertEquals(url.toString(), format("service:jmx:rmi:///jndi/rmi://%s:%s/jmxrmi", address.getHostText(), address.getPort()));

        JMXConnector connector = JMXConnectorFactory.connect(url);
        connector.connect();

        MBeanServerConnection connection = connector.getMBeanServerConnection();
        assertTrue(connection.getMBeanCount() > 0);
    }
}
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.