Package javax.management.remote

Examples of javax.management.remote.JMXConnector

113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
            }
        }
    }

    private boolean isStorageServiceReachable() {
        JMXConnector connector = null;
        try {
            Configuration pluginConfig = getResourceContext().getPluginConfiguration();
            String url = pluginConfig.getSimpleValue("connectorAddress");
            JMXServiceURL serviceURL = new JMXServiceURL(url);
            connector = JMXConnectorFactory.connect(serviceURL, null);

            MBeanServerConnection serverConnection = connector.getMBeanServerConnection();
            ObjectName storageService = new ObjectName("org.apache.cassandra.db:type=StorageService");

            // query an attribute to make sure it is in fact available
            serverConnection.getAttribute(storageService, "NativeTransportRunning");

            return true;
        } catch (Exception e) {
            if (log.isDebugEnabled()) {
                log.debug("Failed to make JMX connection to StorageService", e);
            }
            return false;
        } finally {
            if (connector != null) {
                try {
                    connector.close();
                } catch (IOException e) {
                    if (log.isDebugEnabled()) {
                        log.debug("An error occurred closing the JMX connector", e);
                    }
                }
View Full Code Here
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
                jmxServiceURL = new JMXServiceURL(connectorAddress);
            } catch (MalformedURLException e) {
                throw new RuntimeException("Failed to parse connector address: " + connectorAddress, e);
            }

            JMXConnector jmxConnector = null;
            Long pid;
            try {
                jmxConnector = connect(jmxServiceURL);
                MBeanServerConnection mbeanServerConnection = jmxConnector.getMBeanServerConnection();
                RuntimeMXBean runtimeMXBean = ManagementFactory.newPlatformMXBeanProxy(mbeanServerConnection,
                    ManagementFactory.RUNTIME_MXBEAN_NAME, RuntimeMXBean.class);
                pid = getJvmPid(runtimeMXBean);
                if (pid == null) {
                    throw new RuntimeException("Failed to determine JVM pid by parsing JVM name.");
View Full Code Here
464
465
466
467
468
469
470
471
472
473
474
        }
        return key;
    }

    protected String getJavaVersion(ProcessInfo process, JMXServiceURL jmxServiceURL) {
        JMXConnector jmxConnector = null;
        try {
            jmxConnector = connect(jmxServiceURL);
            return getJavaVersion(jmxConnector);
        } catch (SecurityException e) {
            log.warn("Unable to to authenticate to JMX service URL [" + jmxServiceURL + "]: " + e.getMessage());
View Full Code Here
495
496
497
498
499
500
501
502
503
504
505
        }
        return version;
    }

    private static JMXConnector connect(JMXServiceURL jmxServiceURL) throws IOException {
        JMXConnector jmxConnector;
        try {
            jmxConnector = JMXConnectorFactory.connect(jmxServiceURL);
        } catch (IOException e) {
            throw new IOException("Failed to connect to JMX service URL [" + jmxServiceURL + "].");
        }
View Full Code Here
33
34
35
36
37
38
39
40
41
42
43
44
45
46
        System.out.println(executeCommand("system:shutdown -f", new RolePrincipal("admin")));
    }

    @Test
    public void shutdownViaMBean() throws Exception {
        JMXConnector connector = null;
        try {
            connector = this.getJMXConnector();
            MBeanServerConnection connection = connector.getMBeanServerConnection();
            ObjectName name = new ObjectName("org.apache.karaf:type=system,name=root");
            connection.invoke(name, "halt", new Object[]{}, new String[]{});
        } finally {
          close(connector);
        }
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
47
48
49
        System.out.println(executeCommand("kar:list"));
    }

    @Test
    public void listViaMBean() throws Exception {
        JMXConnector connector = null;
        try {
            connector = this.getJMXConnector();
            MBeanServerConnection connection = connector.getMBeanServerConnection();
            ObjectName name = new ObjectName("org.apache.karaf:type=kar,name=root");
            @SuppressWarnings("unchecked")
            List<String> kars = (List<String>) connection.getAttribute(name, "Kars");
            assertEquals(0, kars.size());
        } finally {
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
58
59
60
        assertFalse(featureListOutput.isEmpty());
    }

    @Test
    public void listViaMBean() throws Exception {
        JMXConnector connector = null;
        try {
            connector = this.getJMXConnector();
            MBeanServerConnection connection = connector.getMBeanServerConnection();
            ObjectName name = new ObjectName("org.apache.karaf:type=feature,name=root");
            TabularData features = (TabularData) connection.getAttribute(name, "Features");
            assertTrue(features.size() > 0);
        } finally {
          close(connector);
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
86
87
88
        assertTrue(featureListOutput.isEmpty());
    }

    @Test
    public void installUninstallViaMBean() throws Exception {
        JMXConnector connector = null;
        try {
            connector = this.getJMXConnector();
            MBeanServerConnection connection = connector.getMBeanServerConnection();
            ObjectName name = new ObjectName("org.apache.karaf:type=feature,name=root");
            connection.invoke(name, "installFeature", new Object[] { "eventadmin" }, new String[]{ "java.lang.String" });
            connection.invoke(name, "uninstallFeature", new Object[] { "eventadmin" }, new String[]{ "java.lang.String" });
        } finally {
          close(connector);
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
108
109
110
        assertContainsNot("apache-karaf-cellar", executeCommand("feature:repo-list"));
    }

    @Test
    public void repoAddRemoveViaMBean() throws Exception {
        JMXConnector connector = null;
        try {
            connector = this.getJMXConnector();
            MBeanServerConnection connection = connector.getMBeanServerConnection();
            ObjectName name = new ObjectName("org.apache.karaf:type=feature,name=root");
            connection.invoke(name, "addRepository", new Object[] { "mvn:org.apache.karaf.cellar/apache-karaf-cellar/2.2.4/xml/features" }, new String[]{ "java.lang.String" });
            connection.invoke(name, "removeRepository", new Object[] { "mvn:org.apache.karaf.cellar/apache-karaf-cellar/2.2.4/xml/features" }, new String[]{ "java.lang.String" });
        } finally {
          close(connector);
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
55
56
57
        assertFalse(listOutput.isEmpty());
    }

    @Test
    public void listViaMBean() throws Exception {
        JMXConnector connector = null;
        try {
            connector = this.getJMXConnector();
            MBeanServerConnection connection = connector.getMBeanServerConnection();
            ObjectName name = new ObjectName("org.apache.karaf:type=web,name=root");
            TabularData webBundles = (TabularData) connection.getAttribute(name, "WebBundles");
            assertEquals(0, webBundles.size());
        } finally {
            close(connector);
View Full Code Here
TOP

Related Classes of javax.management.remote.JMXConnector

  • co.paralleluniverse.common.ProcessUtil
  • com.alibaba.druid.support.console.DruidStat
  • com.alibaba.druid.support.http.StatViewServlet
  • com.alibaba.otter.manager.biz.remote.impl.NodeMBeanServiceImpl
  • com.cloudbees.jmx.JmxInvoker
  • com.comcast.cns.controller.CNSGetAPIStatsAction
  • com.comcast.cns.util.CNSWorkerStatWrapper
  • com.comcast.cqs.controller.CQSGetAPIStatsAction
  • com.neophob.sematrix.cli.PixConClientJmx
  • com.sun.cli.jmx.test.NotificationTester
    • Copyright © 2018 www.massapicom. 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.