Examples of queryMBeanForOne()

Examples of com.taobao.metamorphosis.tools.utils.JMXClient.queryMBeanForOne()

71
72
73
74
75
76
77
78
79
80
81
        int start = Integer.parseInt(commandLine.getOptionValue("start"));
        int end = Integer.parseInt(commandLine.getOptionValue("end"));

        JMXClient jmxClient = JMXClient.getJMXClient(host, port);
        this.println("connected to " + jmxClient.getAddressAsString());
        ObjectInstance metaConfigInstance = jmxClient.queryMBeanForOne(METACONFIG_NAME);

        if (metaConfigInstance != null) {
            jmxClient.invoke(metaConfigInstance.getObjectName(), "closePartitions", new Object[] { topic, start, end },
                new String[] { "java.lang.String", "int", "int" });
            jmxClient.close();
View Full Code Here

Examples of com.taobao.metamorphosis.tools.utils.JMXClient.queryMBeanForOne()

73
74
75
76
77
78
79
80
81
82
83
        JMXClient jmxClient = JMXClient.getJMXClient(host, port);

        this.println("connected to " + jmxClient.getAddressAsString());

        ObjectInstance metaConfigInstance = jmxClient.queryMBeanForOne(HANDLE_NANE);
        if (metaConfigInstance != null) {
            jmxClient.invoke(metaConfigInstance.getObjectName(), "restart", new Object[0], new String[0]);
            jmxClient.close();
            this.println("invoke " + metaConfigInstance.getClassName() + "#restart success");
        }
View Full Code Here

Examples of com.taobao.metamorphosis.tools.utils.JMXClient.queryMBeanForOne()

66
67
68
69
70
71
72
73
74
75
76
        CommandLine commandLine = this.getCommandLine(args);
        String host = commandLine.getOptionValue("host", "127.0.0.1");
        int port = Integer.parseInt(commandLine.getOptionValue("port", "9999"));
        JMXClient jmxClient = JMXClient.getJMXClient(host, port);
        this.println("connected to " + jmxClient.getAddressAsString());
        ObjectInstance ttInstance = jmxClient.queryMBeanForOne(TT_NAME);
        if (ttInstance == null) {
            this.println("û���ҵ� " + TT_NAME);
            return;
        }
        if (commandLine.hasOption("start")) {
View Full Code Here

Examples of com.taobao.metamorphosis.tools.utils.JMXClient.queryMBeanForOne()

74
75
76
77
78
79
80
81
82
83
84
        JMXClient jmxClient = JMXClient.getJMXClient(host, port);

        this.println("connected to " + jmxClient.getAddressAsString());

        ObjectInstance metaConfigInstance = jmxClient.queryMBeanForOne(HANDLE_NANE);
        if (metaConfigInstance != null) {
            Object result = jmxClient.getAttribute(metaConfigInstance.getObjectName(), "Status");
            System.out.println(result);
            jmxClient.close();
            this.println("invoke " + metaConfigInstance.getClassName() + "#reload success");
View Full Code Here

Examples of com.taobao.metamorphosis.tools.utils.JMXClient.queryMBeanForOne()

71
72
73
74
75
76
77
78
79
80
81
        JMXClient jmxClient = JMXClient.getJMXClient(host, port);

        this.println("connected to " + jmxClient.getAddressAsString());

        ObjectInstance metaConfigInstance = jmxClient.queryMBeanForOne(METACONFIG_NAME);
        if (metaConfigInstance != null) {
            jmxClient.invoke(metaConfigInstance.getObjectName(), "reload", new Object[0], new String[0]);
            jmxClient.close();
            this.println("invoke " + metaConfigInstance.getClassName() + "#reload success");
        }
View Full Code Here

Examples of com.taobao.metamorphosis.tools.utils.JMXClient.queryMBeanForOne()

69
70
71
72
73
74
75
76
77
78
79
        int port = Integer.parseInt(commandLine.getOptionValue("port", "9999"));
        String topic = commandLine.getOptionValue("topic");

        JMXClient jmxClient = JMXClient.getJMXClient(host, port);
        this.println("connected to " + jmxClient.getAddressAsString());
        ObjectInstance metaConfigInstance = jmxClient.queryMBeanForOne(METACONFIG_NAME);

        if (metaConfigInstance != null) {
            jmxClient.invoke(metaConfigInstance.getObjectName(), "openPartitions", new Object[] { topic },
                new String[] { "java.lang.String" });
            jmxClient.close();
View Full Code Here

Examples of com.taobao.metamorphosis.tools.utils.JMXClient.queryMBeanForOne()

67
68
69
70
71
72
73
74
75
76
77
        String host = commandLine.getOptionValue("host", "127.0.0.1");
        int port = Integer.parseInt(commandLine.getOptionValue("port", "9999"));

        JMXClient jmxClient = JMXClient.getJMXClient(host, port);
        this.println("connected to " + jmxClient.getAddressAsString());
        ObjectInstance brokerInstance = jmxClient.queryMBeanForOne(METABROKER_NAME);

        if (brokerInstance != null) {
            jmxClient.invoke(brokerInstance.getObjectName(), "stop", new Object[0], new String[0]);
            jmxClient.close();
            this.println("invoke " + brokerInstance.getClassName() + "#stop success");
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.