diff options
Diffstat (limited to 'java/management/cli')
20 files changed, 0 insertions, 1404 deletions
diff --git a/java/management/cli/bin/stac.bat b/java/management/cli/bin/stac.bat deleted file mode 100644 index 5377ca9d2c..0000000000 --- a/java/management/cli/bin/stac.bat +++ /dev/null @@ -1,41 +0,0 @@ -@REM
-@REM Licensed to the Apache Software Foundation (ASF) under one
-@REM or more contributor license agreements. See the NOTICE file
-@REM distributed with this work for additional information
-@REM regarding copyright ownership. The ASF licenses this file
-@REM to you under the Apache License, Version 2.0 (the
-@REM "License"); you may not use this file except in compliance
-@REM with the License. You may obtain a copy of the License at
-@REM
-@REM http://www.apache.org/licenses/LICENSE-2.0
-@REM
-@REM Unless required by applicable law or agreed to in writing,
-@REM software distributed under the License is distributed on an
-@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-@REM KIND, either express or implied. See the License for the
-@REM specific language governing permissions and limitations
-@REM under the License.
-@REM
-
-@echo off
-set COREROOT=..\..\core
-set AMQROOT=..\..\..\clients_java
-
-set CP=..\lib\jython\jython.jar
-set CP=%CP%;..\dist\amqp-stac.jar
-set CP=%CP%;%COREROOT%\dist\amqp-management-common.jar
-set CP=%CP%;%COREROOT%\lib\log4j\log4j-1.2.9.jar
-set CP=%CP%;%COREROOT%\lib\xmlbeans\jsr173_api.jar
-set CP=%CP%;%COREROOT%\lib\xmlbeans\resolver.jar
-set CP=%CP%;%COREROOT%\lib\xmlbeans\xbean.jar
-set CP=%CP%;%COREROOT%\lib\xmlbeans\xbean_xpath.jar
-set CP=%CP%;%COREROOT%\lib\xmlbeans\xmlpublic.jar
-set CP=%CP%;%COREROOT%\lib\xmlbeans\saxon8.jar
-set CP=%CP%;%AMQROOT%\dist\amqp-common.jar
-set CP=%CP%;%AMQROOT%\dist\amqp-jms.jar
-set CP=%CP%;%AMQROOT%\lib\mina\mina-0.7.3.jar
-set CP=%CP%;%AMQROOT%\lib\jms\jms.jar
-set CP=%CP%;%AMQROOT%\lib\util-concurrent\backport-util-concurrent.jar
-set CP=%CP%;%AMQROOT%\lib\jakarta-commons\commons-collections-3.1.jar
-
-%JAVA_HOME%\bin\java -Damqj.logging.level="ERROR" -cp %CP% org.apache.qpid.stac.Stac
diff --git a/java/management/cli/bin/stac.sh b/java/management/cli/bin/stac.sh deleted file mode 100755 index 5858d88db4..0000000000 --- a/java/management/cli/bin/stac.sh +++ /dev/null @@ -1,42 +0,0 @@ -#!/bin/sh -# -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# - - -COREROOT=../../core -AMQROOT=../../../clients_java - -CP=../lib/jython/jython.jar -CP=$CP:../dist/amqp-stac.jar -CP=$CP:$COREROOT/dist/amqp-management-common.jar -CP=$CP:$COREROOT/lib/log4j/log4j-1.2.9.jar -CP=$CP:$COREROOT/lib/xmlbeans/jsr173_api.jar -CP=$CP:$COREROOT/lib/xmlbeans/resolver.jar -CP=$CP:$COREROOT/lib/xmlbeans/xbean.jar -CP=$CP:$COREROOT/lib/xmlbeans/xbean_xpath.jar -CP=$CP:$COREROOT/lib/xmlbeans/xmlpublic.jar -CP=$CP:$COREROOT/lib/xmlbeans/saxon8.jar -CP=$CP:$AMQROOT/dist/amqp-common.jar -CP=$CP:$AMQROOT/dist/amqp-jms.jar -CP=$CP:$AMQROOT/lib/mina/mina-0.7.3.jar -CP=$CP:$AMQROOT/lib/jms/jms.jar -CP=$CP:$AMQROOT/lib/util-concurrent/backport-util-concurrent.jar -CP=$CP:$AMQROOT/lib/jakarta-commons/commons-collections-3.1.jar - -$JAVA_HOME/bin/java -Damqj.logging.level="ERROR" -cp $CP org.apache.qpid.stac.Stac diff --git a/java/management/cli/bin/stacDEV.bat b/java/management/cli/bin/stacDEV.bat deleted file mode 100644 index c01feea60d..0000000000 --- a/java/management/cli/bin/stacDEV.bat +++ /dev/null @@ -1,44 +0,0 @@ -@REM
-@REM Licensed to the Apache Software Foundation (ASF) under one
-@REM or more contributor license agreements. See the NOTICE file
-@REM distributed with this work for additional information
-@REM regarding copyright ownership. The ASF licenses this file
-@REM to you under the Apache License, Version 2.0 (the
-@REM "License"); you may not use this file except in compliance
-@REM with the License. You may obtain a copy of the License at
-@REM
-@REM http://www.apache.org/licenses/LICENSE-2.0
-@REM
-@REM Unless required by applicable law or agreed to in writing,
-@REM software distributed under the License is distributed on an
-@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-@REM KIND, either express or implied. See the License for the
-@REM specific language governing permissions and limitations
-@REM under the License.
-@REM
-
-@echo off
-set COREROOT=..\..\core
-set AMQROOT=..\..\..\clients_java
-
-set CP=..\lib\jython\jython.jar
-set CP=%CP%;..\intellijclasses
-set CP=%CP%;%COREROOT%\intellijclasses
-set CP=%CP%;%COREROOT%\classes
-set CP=%CP%;%COREROOT%\lib\log4j\log4j-1.2.9.jar
-set CP=%CP%;%COREROOT%\lib\xmlbeans\jsr173_api.jar
-set CP=%CP%;%COREROOT%\lib\xmlbeans\resolver.jar
-set CP=%CP%;%COREROOT%\lib\xmlbeans\xbean.jar
-set CP=%CP%;%COREROOT%\lib\xmlbeans\xbean_xpath.jar
-set CP=%CP%;%COREROOT%\lib\xmlbeans\xmlpublic.jar
-set CP=%CP%;%COREROOT%\lib\xmlbeans\saxon8.jar
-set CP=%CP%;%AMQROOT%\dist\amqp-common.jar
-set CP=%CP%;%AMQROOT%\dist\amqp-jms.jar
-set CP=%CP%;%AMQROOT%\lib\mina\mina-0.7.3.jar
-set CP=%CP%;%AMQROOT%\lib\jms\jms.jar
-set CP=%CP%;%AMQROOT%\lib\util-concurrent\backport-util-concurrent.jar
-set CP=%CP%;%AMQROOT%\lib\jakarta-commons\commons-collections-3.1.jar
-
-
-@rem %JAVA_HOME%\bin\java -Damqj.logging.level="ERROR" -Xdebug -Xnoagent -Djava.compiler=NONE -Xrunjdwp:transport=dt_socket,server=y,suspend=n,address=5005 -cp %CP% org.amqp.blaze.stac.Stac
-%JAVA_HOME%\bin\java -Damqj.logging.level="ERROR" -cp %CP% org.amqp.blaze.stac.Stac
\ No newline at end of file diff --git a/java/management/cli/build-module.xml b/java/management/cli/build-module.xml deleted file mode 100644 index 58a160a608..0000000000 --- a/java/management/cli/build-module.xml +++ /dev/null @@ -1,24 +0,0 @@ -<!-- - - - - Licensed to the Apache Software Foundation (ASF) under one - - or more contributor license agreements. See the NOTICE file - - distributed with this work for additional information - - regarding copyright ownership. The ASF licenses this file - - to you under the Apache License, Version 2.0 (the - - "License"); you may not use this file except in compliance - - with the License. You may obtain a copy of the License at - - - - http://www.apache.org/licenses/LICENSE-2.0 - - - - Unless required by applicable law or agreed to in writing, - - software distributed under the License is distributed on an - - "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - - KIND, either express or implied. See the License for the - - specific language governing permissions and limitations - - under the License. - - - --> -<project name="AMQ Management Client" default="build"> - <property name="module.depends" value="common,client,management/core"/> - <import file="../../module.xml"/> -</project> diff --git a/java/management/cli/build-old.xml b/java/management/cli/build-old.xml deleted file mode 100644 index cb4e34b35d..0000000000 --- a/java/management/cli/build-old.xml +++ /dev/null @@ -1,125 +0,0 @@ -<?xml version="1.0"?> -<!-- - - - - Licensed to the Apache Software Foundation (ASF) under one - - or more contributor license agreements. See the NOTICE file - - distributed with this work for additional information - - regarding copyright ownership. The ASF licenses this file - - to you under the Apache License, Version 2.0 (the - - "License"); you may not use this file except in compliance - - with the License. You may obtain a copy of the License at - - - - http://www.apache.org/licenses/LICENSE-2.0 - - - - Unless required by applicable law or agreed to in writing, - - software distributed under the License is distributed on an - - "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - - KIND, either express or implied. See the License for the - - specific language governing permissions and limitations - - under the License. - - - --> - -<!-- AMQP STAC Java build file --> - -<project name="management-stac" default="jar" basedir="."> - <property name="lib" value="${basedir}/lib"/> - <property name="src" value="${basedir}/src"/> - <property name="tests" value="${basedir}/test"/> - <property name="classes" value="${basedir}/classes"/> - <property name="testclasses" value="${basedir}/testclasses"/> - <property name="dist" value="${basedir}/dist"/> - <property name="amqp.root" value="${basedir}/../../clients_java"/> - <property name="amqp.lib" value="${amqp.root}/lib"/> - <property name="amqp.dist" value="${amqp.root}/dist"/> - <property name="managementcore.root" value="${basedir}/../core"/> - <property name="managementcore.dist" value="${managementcore.root}/dist"/> - <property name="managementcore.lib" value="${managementcore.root}/lib"/> - - <!-- Setup details --> - <target name="init"> - <tstamp> - <format property="release" pattern="-dMMMyy" locale="en" timezone="GMT"/> - </tstamp> - - <mkdir dir="${classes}"/> - <mkdir dir="${testclasses}"/> - <mkdir dir="${dist}"/> - </target> - - <path id="core.classpath"> - <fileset dir="${lib}"> - <include name="**/*.jar"/> - </fileset> - <pathelement path="${classes}"/> - <pathelement path="${testclasses}/"/> - <fileset dir="${managementcore.dist}"> - <include name="**/*.jar"/> - </fileset> - <fileset dir="${managementcore.lib}"> - <include name="**/*.jar"/> - </fileset> - <fileset dir="${amqp.dist}"> - <include name="**/*.jar"/> - </fileset> - <fileset dir="${amqp.lib}"> - <include name="**/*.jar"/> - </fileset> - </path> - - <!-- Remove all built files --> - <target name="clean" depends="init"> - <delete dir="${classes}"/> - <delete dir="${dist}"/> - <delete dir="${testclasses}"/> - </target> - - <!-- Compile Java --> - <target name="compile" depends="init"> - <javac destdir="${classes}" target="1.5" source="1.5" debug="on"> - <classpath refid="core.classpath"/> - <src path="${src}"/> - </javac> - - <copy todir="${classes}"> - <!-- copy any non java src files into the build tree, e.g. log4j.properties --> - <fileset dir="${src}"> - <exclude name="**/*.java"/> - <exclude name="**/package.html"/> - </fileset> - </copy> - </target> - - - <target name="compiletests" depends="compile"> - <javac destdir="${testclasses}" target="1.5" source="1.5" classpathref="core.classpath" - debug="on"> - <src path="${tests}"/> - </javac> - - <copy todir="${testclasses}"> - <!-- copy any non java src files into the build tree, e.g. log4j.properties --> - <fileset dir="${tests}"> - <exclude name="**/*.java"/> - <exclude name="**/package.html"/> - </fileset> - </copy> - </target> - - <!-- Build jar archive --> - <target name="jar" depends="compiletests"> - <mkdir dir="${dist}"/> - <jar basedir="${classes}" jarfile="${dist}/amqp-stac.jar"/> - <jar basedir="${testclasses}" jarfile="${dist}/amqp-stac-tests.jar"/> - </target> - - - <target name="javadoc" depends="compile, compiletests"> - <mkdir dir="${dist}/docs/api"/> - <javadoc sourcepath="${src}" destdir="${dist}/docs/api" - packagenames="org.apache.qpid.*" classpathref="amqp.classpath" author="true" - version="true" windowTitle="AMQP STAC API" doctitle="AMQP STAC API" - footer="See <a href="http://www.amqp.org">www.amqp.org</a> for more information." - use="true" verbose="false"/> - </target> -</project> diff --git a/java/management/cli/lib/jython/jython.jar b/java/management/cli/lib/jython/jython.jar Binary files differdeleted file mode 100644 index 517c60dd0e..0000000000 --- a/java/management/cli/lib/jython/jython.jar +++ /dev/null diff --git a/java/management/cli/lib/jython/license.jython.txt b/java/management/cli/lib/jython/license.jython.txt deleted file mode 100644 index 48eb403585..0000000000 --- a/java/management/cli/lib/jython/license.jython.txt +++ /dev/null @@ -1,32 +0,0 @@ -Jython changes Software License. -================================ - -Copyright (c) 2000, Jython Developers -All rights reserved. - -Redistribution and use in source and binary forms, with or without -modification, are permitted provided that the following conditions -are met: - - - Redistributions of source code must retain the above copyright - notice, this list of conditions and the following disclaimer. - - - Redistributions in binary form must reproduce the above copyright - notice, this list of conditions and the following disclaimer in - the documentation and/or other materials provided with the distribution. - - - Neither the name of the Jython Developers nor the names of - its contributors may be used to endorse or promote products - derived from this software without specific prior written permission. - -THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS -``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT -LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR -A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR -CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, -EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, -PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR -PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY -OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING -NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS -SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. diff --git a/java/management/cli/src/org/apache/qpid/stac/Stac.java b/java/management/cli/src/org/apache/qpid/stac/Stac.java deleted file mode 100644 index 0ee0f842f4..0000000000 --- a/java/management/cli/src/org/apache/qpid/stac/Stac.java +++ /dev/null @@ -1,97 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ -package org.apache.qpid.stac; - -import java.io.BufferedReader; -import java.io.IOException; -import java.io.InputStreamReader; -import java.io.InputStream; - -public class Stac -{ - public static void main(String[] args) - { - BufferedReader terminal = new BufferedReader(new InputStreamReader(System.in)); - System.out.println("\nInitializing the Scripting Tool for AMQ Console (STAC) ..."); - String var = System.getProperty("python.verbose"); - if (var != null) - { - System.setProperty("python.verbose", var); - } - else - { - System.setProperty("python.verbose", "warning"); - } - StacInterpreter interp = new StacInterpreter(); - InputStream is = Stac.class.getResourceAsStream("/python/stac.py"); - if (is == null) - { - System.err.println("Unable to load STAC Python library. Terminating."); - System.exit(1); - } - interp.execfile(is); - - boolean running = true; - - while (running) - { - interp.write(interp.get("commandPrompt").toString()); - - String line = null; - try - { - line = terminal.readLine(); - if (line != null) - { - if (line.equalsIgnoreCase("quit") || line.equalsIgnoreCase("exit")) - { - running = false; - line = "quit()"; - } - while (interp.runsource(line)) - { - interp.write("..."); - try - { - String s = terminal.readLine(); - line = line + "\n" + s; - } - catch (IOException e) - { - e.printStackTrace(); - } - } - } - else - { - System.out.println(); - running = false; - } - } - catch (IOException ie) - { - System.err.println("An error occurred: " + ie); - ie.printStackTrace(System.err); - } - } - System.exit(0); - } -} diff --git a/java/management/cli/src/org/apache/qpid/stac/StacInterpreter.java b/java/management/cli/src/org/apache/qpid/stac/StacInterpreter.java deleted file mode 100644 index 00e03ac109..0000000000 --- a/java/management/cli/src/org/apache/qpid/stac/StacInterpreter.java +++ /dev/null @@ -1,34 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ -package org.apache.qpid.stac; - -import org.python.util.InteractiveInterpreter; -import org.python.core.PySystemState; - -public class StacInterpreter extends InteractiveInterpreter -{ - public StacInterpreter() - { - PySystemState.initialize(); - super.set("theInterpreter", this); - super.exec("import sys\n"); - } -} diff --git a/java/management/cli/src/org/apache/qpid/stac/commands/CdCommand.java b/java/management/cli/src/org/apache/qpid/stac/commands/CdCommand.java deleted file mode 100644 index 1a1fb7470c..0000000000 --- a/java/management/cli/src/org/apache/qpid/stac/commands/CdCommand.java +++ /dev/null @@ -1,53 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ -package org.apache.qpid.stac.commands; - -import org.apache.qpid.stac.jmx.MBeanServerConnectionContext; -import org.apache.qpid.stac.jmx.CurrentMBean; -import org.apache.qpid.AMQException; - -public class CdCommand -{ - public static void execute(MBeanServerConnectionContext context, String destination) - throws AMQException - { - // check if it is an absolute path and if so change to the root first - if (destination.startsWith("/")) - { - context.changeBean("/"); - destination = destination.substring(1); - } - if (destination.length() == 0) - { - return; - } - String[] destinations = destination.split("/"); - for (String item : destinations) - { - if ("..".equals(item)) - { - item = CurrentMBean.PARENT_ATTRIBUTE; - } - context.changeBean(item); - } - } - -} diff --git a/java/management/cli/src/org/apache/qpid/stac/commands/InvokeCommand.java b/java/management/cli/src/org/apache/qpid/stac/commands/InvokeCommand.java deleted file mode 100644 index b9728416e0..0000000000 --- a/java/management/cli/src/org/apache/qpid/stac/commands/InvokeCommand.java +++ /dev/null @@ -1,34 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ -package org.apache.qpid.stac.commands; - -import org.apache.qpid.stac.jmx.MBeanServerConnectionContext; -import org.apache.qpid.AMQException; - -public class InvokeCommand -{ - public static void execute(MBeanServerConnectionContext context, String methodName, Object... args) - throws AMQException - { - // Not used currently - - } -} diff --git a/java/management/cli/src/org/apache/qpid/stac/commands/LsCommand.java b/java/management/cli/src/org/apache/qpid/stac/commands/LsCommand.java deleted file mode 100644 index 6d7006a3c9..0000000000 --- a/java/management/cli/src/org/apache/qpid/stac/commands/LsCommand.java +++ /dev/null @@ -1,126 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ -package org.apache.qpid.stac.commands; - -import org.apache.qpid.AMQException; -import org.apache.qpid.stac.jmx.CurrentMBean; -import org.apache.qpid.stac.jmx.MBeanServerConnectionContext; -import org.apache.qpid.stac.jmx.MBeanUtils; - -import javax.management.MBeanAttributeInfo; -import javax.management.MBeanOperationInfo; -import javax.management.MBeanParameterInfo; -import java.util.SortedSet; - -public class LsCommand -{ - public static void execute(MBeanServerConnectionContext context) - throws AMQException - { - CurrentMBean currentMBean = context.getCurrentMBean(); - - SortedSet<MBeanAttributeInfo> directories = currentMBean.getOrderedObjects(); - System.out.println(); - for (MBeanAttributeInfo ai : directories) - { - if (!MBeanUtils.isHidden(ai)) - { - outputAccess(ai); - System.out.println(" " + ai.getName()); - } - } - System.out.println(); - - SortedSet<MBeanAttributeInfo> attributes = currentMBean.getOrderedAttributes(); - for (MBeanAttributeInfo ai : attributes) - { - outputAccess(ai); - System.out.printf(" %1$-15s%2$-15s %3$s\n", ai.getName(), "[" + convertType(ai.getType()) + "]", - currentMBean.getAttributeValue(ai.getName(), ai.getType())); - } - System.out.println(); - SortedSet<MBeanOperationInfo> operations = currentMBean.getOrderedOperations(); - - for (MBeanOperationInfo oi : operations) - { - System.out.printf("-r-x %1$-15s", oi.getName()); - MBeanParameterInfo[] paramInfos = oi.getSignature(); - System.out.print("["); - if (paramInfos.length == 0) - { - System.out.print("No arguments"); - } - - for (int i = 0; i < paramInfos.length; i++) - { - MBeanParameterInfo pi = paramInfos[i]; - System.out.printf("%1$s:%2$s%3$s", pi.getName(), convertType(pi.getType()), - (i < paramInfos.length)?",":""); - } - System.out.println("]"); - } - System.out.println(); - } - - private static void outputAccess(MBeanAttributeInfo ai) - { - boolean isObject = ai.getType().equals("javax.management.ObjectName"); - System.out.print(isObject?"d":"-"); - System.out.print(ai.isReadable()?"r":"-"); - System.out.print(ai.isWritable()?"w":"-"); - System.out.print("-"); - } - - /** - * Converts the type name to a non-Java type (e.g. java.lang.String -> String) - * @param javaType - * @return a generic type - */ - private static String convertType(String javaType) - { - if ("java.lang.String".equals(javaType)) - { - return "String"; - } - else if ("java.lang.Integer".equals(javaType)) - { - return "Integer"; - } - else if ("java.lang.Boolean".equals(javaType)) - { - return "Boolean"; - } - else if ("java.lang.Double".equals(javaType)) - { - return "Double"; - } - else if ("java.util.Date".equals(javaType)) - { - return "Date"; - } - else - { - return javaType; - } - } - - -} diff --git a/java/management/cli/src/org/apache/qpid/stac/jmx/CurrentMBean.java b/java/management/cli/src/org/apache/qpid/stac/jmx/CurrentMBean.java deleted file mode 100644 index e1163bf6ce..0000000000 --- a/java/management/cli/src/org/apache/qpid/stac/jmx/CurrentMBean.java +++ /dev/null @@ -1,183 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ -package org.apache.qpid.stac.jmx; - -import org.apache.qpid.AMQException; - -import javax.management.*; -import java.text.SimpleDateFormat; -import java.util.*; - -/** - * Stores information about the "current" MBean. This data is used when navigating the hierarchy. - * - * For example, we need to map between a name and an object id, and this stores that link. - * - */ -public class CurrentMBean -{ - private MBeanServerConnection _mbeanServerConnection; - - public static final String PARENT_ATTRIBUTE = "__parent"; - - private static final SimpleDateFormat _dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - /** - * Maps names to ObjectNames. Used for efficiency to avoid iterating through all names when doing a CD command. - */ - private Map<String, ObjectName> _name2ObjectNameMap = new HashMap<String, ObjectName>(); - - private ObjectName _mbeanObjectName; - - private MBeanInfo _mbeanInfo; - - public CurrentMBean(MBeanServerConnection mbeanServerConnection) - { - _mbeanServerConnection = mbeanServerConnection; - } - - public void changeMBean(ObjectName objectName) throws AMQException - { - try - { - _mbeanInfo = _mbeanServerConnection.getMBeanInfo(objectName); - } - catch (Exception e) - { - throw new AMQException("Unable to look up MBean for object name " + objectName + ": " + e, e); - } - _mbeanObjectName = objectName; - } - - public ObjectName getMBeanObjectName() - { - return _mbeanObjectName; - } - - public MBeanInfo getMBeanInfo() - { - return _mbeanInfo; - } - - public Object getAttributeValue(String name, String type) throws AMQException - { - // TODO: The type argument is a temporary workaround for a bug (somewhere!) in which - // a date is returned as a String - try - { - Object o = _mbeanServerConnection.getAttribute(_mbeanObjectName, name); - if ("java.util.Date".equals(type)) - { - - return _dateFormat.format(new Date(Long.parseLong((String)o))); - } - else - { - return o; - } - } - catch (Exception e) - { - throw new AMQException("Unable to read attribute value for attribute name " + name, e); - } - } - - /** - * Get the objects (i.e. "directories") under the current mbean, ordered alphabetically. This method also - * refreshes the cache that maps from name to ObjectName (this saves iterating through the attributes again). - * @return a set containing the attribute infos, sorted by name - */ - public SortedSet<MBeanAttributeInfo> getOrderedObjects() throws AMQException - { - TreeSet<MBeanAttributeInfo> attributes = new TreeSet<MBeanAttributeInfo>(new MBeanAttributeInfoComparator()); - _name2ObjectNameMap.clear(); - for (MBeanAttributeInfo ai : _mbeanInfo.getAttributes()) - { - String type = ai.getType(); - - if ("javax.management.ObjectName".equals(type)) - { - _name2ObjectNameMap.put(ai.getName(), (ObjectName)getAttributeValue(ai.getName(), type)); - attributes.add(ai); - } - } - return attributes; - } - - public void refreshNameToObjectNameMap() throws AMQException - { - _name2ObjectNameMap.clear(); - for (MBeanAttributeInfo ai : _mbeanInfo.getAttributes()) - { - final String type = ai.getType(); - - if ("javax.management.ObjectName".equals(type)) - { - _name2ObjectNameMap.put(ai.getName(), (ObjectName)getAttributeValue(ai.getName(), type)); - } - } - } - - /** - * Gets an object name, given the "display name" - * @param name the display name (usually returned to the user when he does an ls() - * @return the object name - */ - public ObjectName getObjectNameByName(String name) - { - return _name2ObjectNameMap.get(name); - } - - public SortedSet<MBeanAttributeInfo> getOrderedAttributes() - { - TreeSet<MBeanAttributeInfo> attributes = new TreeSet<MBeanAttributeInfo>(new MBeanAttributeInfoComparator()); - for (MBeanAttributeInfo ai : _mbeanInfo.getAttributes()) - { - String type = ai.getType(); - if (!"javax.management.ObjectName".equals(type)) - { - attributes.add(ai); - } - } - return attributes; - } - - public SortedSet<MBeanOperationInfo> getOrderedOperations() - { - TreeSet<MBeanOperationInfo> operations = new TreeSet<MBeanOperationInfo>(new MBeanOperationInfoComparator()); - for (MBeanOperationInfo oi : _mbeanInfo.getOperations()) - { - operations.add(oi); - } - return operations; - } - - public void invoke(String methodName, Object... args) throws AMQException - { - try - { - _mbeanServerConnection.invoke(_mbeanObjectName, methodName, null, null); - } - catch (Exception e) - { - throw new AMQException("Error invoking method " + methodName + ": " + e, e); - } - } -} diff --git a/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanAttributeInfoComparator.java b/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanAttributeInfoComparator.java deleted file mode 100644 index 534b9bbb9e..0000000000 --- a/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanAttributeInfoComparator.java +++ /dev/null @@ -1,32 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ -package org.apache.qpid.stac.jmx; - -import javax.management.MBeanAttributeInfo; -import java.util.Comparator; - -public class MBeanAttributeInfoComparator implements Comparator<MBeanAttributeInfo> -{ - public int compare(MBeanAttributeInfo o1, MBeanAttributeInfo o2) - { - return o1.getName().compareTo(o2.getName()); - } -} diff --git a/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanOperationInfoComparator.java b/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanOperationInfoComparator.java deleted file mode 100644 index a1a7422fe3..0000000000 --- a/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanOperationInfoComparator.java +++ /dev/null @@ -1,32 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ -package org.apache.qpid.stac.jmx; - -import javax.management.MBeanOperationInfo; -import java.util.Comparator; - -public class MBeanOperationInfoComparator implements Comparator<MBeanOperationInfo> -{ - public int compare(MBeanOperationInfo o1, MBeanOperationInfo o2) - { - return o1.getName().compareTo(o2.getName()); - } -} diff --git a/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanServerConnectionContext.java b/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanServerConnectionContext.java deleted file mode 100644 index 300a617cd5..0000000000 --- a/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanServerConnectionContext.java +++ /dev/null @@ -1,205 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ -package org.apache.qpid.stac.jmx; - -import org.apache.qpid.AMQException; -import org.apache.qpid.management.jmx.JmxConstants; -import org.apache.qpid.stac.commands.CdCommand; -import org.apache.qpid.stac.commands.LsCommand; -import org.apache.log4j.Logger; - -import javax.management.MBeanServerConnection; -import javax.management.MalformedObjectNameException; -import javax.management.ObjectName; -import javax.management.ObjectInstance; -import javax.management.remote.JMXConnector; -import javax.management.remote.JMXConnectorFactory; -import javax.management.remote.JMXServiceURL; -import java.lang.management.ManagementFactory; -import java.util.Hashtable; -import java.util.Set; - -public class MBeanServerConnectionContext -{ - private static final Logger _log = Logger.getLogger(MBeanServerConnectionContext.class); - - /** - * The connection to the MBean server. Can be remote or local, depending on whether we are proxying. - */ - private MBeanServerConnection _connection; - - /** - * The connector used to make the connection to the remote MBean server - */ - private JMXConnector _connector; - - private CurrentMBean _currentMBean; - - /* - * Initialize connection to the Domain Runtime MBean Server - */ - public void connect(String host) throws AMQException - { - if (host == null) - { - _connection = (MBeanServerConnection) ManagementFactory.getPlatformMBeanServer(); - } - else - { - String serviceURLString = "service:jmx:local://localhost"; - - try - { - JMXServiceURL serviceURL = new JMXServiceURL(serviceURLString); - _connector = JMXConnectorFactory.connect(serviceURL, null); - _connection = _connector.getMBeanServerConnection(); - } - catch (Exception e) - { - throw new AMQException("Unable to connect to remote MBean server with service url " + serviceURLString + - ": " + e, e); - } - } - _currentMBean = new CurrentMBean(_connection); - changeBean(getRootObjectName()); - } - - /** - * Connect to the local MBean server - * @throws AMQException - */ - public void connect() throws AMQException - { - connect(null); - } - - public void disconnect() throws AMQException - { - if (_connection != null) - { - try - { - ObjectName queryName = new ObjectName(JmxConstants.JMX_DOMAIN + ":*"); - Set<ObjectInstance> beans = _connection.queryMBeans(queryName, null); - for (ObjectInstance bean : beans) - { - _log.debug("Unregistering MBean: " + bean.getObjectName()); - _connection.unregisterMBean(bean.getObjectName()); - } - } - catch (Exception e) - { - throw new AMQException("Error unregistering MBeans: " + e, e); - } - } - } - - public ObjectName getRootObjectName() throws AMQException - { - Hashtable<String, String> props = new Hashtable<String, String>(); - props.put("objectid", "0"); - props.put("type", "broker"); - try - { - return new ObjectName(JmxConstants.JMX_DOMAIN, props); - } - catch (MalformedObjectNameException e) - { - throw new AMQException("Cannot construct root MBean object name: " + e, e); - } - } - - private void changeBean(ObjectName objectName) throws AMQException - { - _currentMBean.changeMBean(objectName); - } - - /** - * Change the current bean to the one underneath the current bean, represented by the display name - * @param name - * @throws AMQException - */ - public void changeBean(String name) throws AMQException - { - checkConnection(); - if (name.equals("/")) - { - changeBean(getRootObjectName()); - } - else - { - ObjectName objName = _currentMBean.getObjectNameByName(name); - if (CurrentMBean.PARENT_ATTRIBUTE.equals(name) && objName == null) - { - // we have tried to change up a level from the root, so just ignore - return; - } - if (objName == null) - { - // could be stale cache, so refresh - _currentMBean.refreshNameToObjectNameMap(); - objName = _currentMBean.getObjectNameByName(name); - } - if (objName == null) - { - throw new AMQException("Unknown managed object with name: " + name); - } - else - { - changeBean(objName); - } - } - } - - public void ls() throws AMQException - { - checkConnection(); - LsCommand.execute(this); - } - - public void cd(String destination) throws AMQException - { - CdCommand.execute(this, destination); - } - - public void invoke(String methodName, Object... args) throws AMQException - { - _currentMBean.invoke(methodName, args); - } - - public CurrentMBean getCurrentMBean() - { - return _currentMBean; - } - - public MBeanServerConnection getMBeanServerConnection() - { - return _connection; - } - - private void checkConnection() throws NotConnectedException - { - if (_connection == null) - { - throw new NotConnectedException(); - } - } -} diff --git a/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanUtils.java b/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanUtils.java deleted file mode 100644 index 2447322166..0000000000 --- a/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanUtils.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ -package org.apache.qpid.stac.jmx; - -import javax.management.MBeanAttributeInfo; - -/** - * Useful MBean methods. Also provides functionality for our CMLMBean - */ -public class MBeanUtils -{ - public static boolean isHidden(MBeanAttributeInfo ai) - { - /* This is JDK 1.6 only - String hidden = (String) ai.getDescriptor().getFieldValue("hidden"); - return hidden != null && "true".equals(hidden); - */ - return ai.getName().startsWith("__"); - } -} diff --git a/java/management/cli/src/org/apache/qpid/stac/jmx/NotConnectedException.java b/java/management/cli/src/org/apache/qpid/stac/jmx/NotConnectedException.java deleted file mode 100644 index 1fbc1501b5..0000000000 --- a/java/management/cli/src/org/apache/qpid/stac/jmx/NotConnectedException.java +++ /dev/null @@ -1,31 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ -package org.apache.qpid.stac.jmx; - -import org.apache.qpid.AMQException; - -public class NotConnectedException extends AMQException -{ - public NotConnectedException() - { - super("Not connected to JMX server"); - } -} diff --git a/java/management/cli/src/python/stac.py b/java/management/cli/src/python/stac.py deleted file mode 100644 index 6a7230d724..0000000000 --- a/java/management/cli/src/python/stac.py +++ /dev/null @@ -1,193 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# - -""" -Bridges between Python and Java, to provide a simpler and more Pythonesque environment. -Certified to be free of dead parrots. -""" -# Imports -from java.lang import * -import org.amqp.blaze.management.jmx.AMQConsole as AMQConsole -import org.amqp.blaze.stac.jmx.MBeanServerConnectionContext as MBeanServerConnectionContext - -# Globals -commandPrompt = "" -proxied = 0 -connected = 0 -amqConsole = None -connectionContext = None - -# Functions -def connect(url="", username="", password=""): - """ - Connects to an AMQP broker. The URL must be in the form amq://host:port/context - """ - try: - global connected - global connectionContext - if connected==1: - print "Already Connected!" - return - - try: - parsedURL = parseURL(url) - except URLFormatError, ufe: - print "Invalid URL: " + ufe.msg - return - - amqConsole = AMQConsole(parsedURL['host'], parsedURL['port'], username, password, parsedURL['context']) - - amqConsole.initialise() - amqConsole.registerAllMBeans() - connectionContext = MBeanServerConnectionContext() - connectionContext.connect() - connected = 1 - except Exception, e: - updateGlobals() - print e - e.printStackTrace() - cause = e.getCause() - if cause != None: - cause.printStackTrace() - else: - updateGlobals(); - -def disconnect(): - """ - Disconnects from the broker - """ - global connected - global connectionContext - - if connected==0: - print "Not connected!" - return - try: - connectionContext.disconnect() - connected = 0 - except Exception, e: - updateGlobals() - print e - else: - updateGlobals() - -def quit(): - global connected - if connected != 0: - disconnect() - -def ls(): - """ - Lists the current mbean - """ - global connected - if connected == 0: - print "Not connected!" - return - - connectionContext.ls() - -def cd(beanName): - """ - Changes the current mbean - """ - global connected - global connectionContext - if connected == 0: - print "Not connected!" - return - - try: - connectionContext.cd(beanName) - except Exception, e: - updateGlobals() - msg = "Error: " + e.getMessage() - print msg - else: - updateGlobals() - -def invoke(methodName): - """ - Invokes an operation of the current mbean - """ - global connected - global connectionContext - - if connected == 0: - print "Not connected!" - return - - try: - connectionContext.invoke(methodName, None) - except Exception, e: - updateGlobals() - msg = "Error: " + e.getMessage() - print msg - else: - updateGlobals() - -class URLFormatError(Exception): - """Exception raised for errors in format of the URL - - Attributes: - expression -- input expression in which the error occurred - message -- explanation of the error - """ - - def __init__(self, url, message): - self.url = url - self.msg = message - -def parseURL(url): - """ - Parses an AMQ URL into host, port and context components returning them in a dictionary - """ - idx = url.find("amq://") - errorMsg = "Invalid URL - must be format amq://hostname:port/vhost" - if idx != 0: - raise URLFormatError(url, errorMsg) - - hostEndIdx = url.find(":", 6) - if hostEndIdx == -1: - raise URLFormatError(url, errorMsg) - - hostname = url[6:hostEndIdx] - - portIdx = url.find("/", hostEndIdx + 1) - port = url[hostEndIdx + 1:portIdx] - vhost = url[portIdx + 1:] - if portIdx == -1: - raise URLFormatError(url, errorMsg) - - return {'host':hostname,'port':int(port),'context':vhost} - -def updateGlobals(): - global commandPrompt - global connectionContext - if connected == 1: - commandPrompt = "AMQ:connected#" + connectionContext.getCurrentMBean().getAttributeValue("name", "java.lang.String") + "> " - else: - commandPrompt = "AMQ:disconnected> " -# Classes - - -# Global execution - -# Update all the global variables - this is called to sync everything at the start -updateGlobals() diff --git a/java/management/cli/test/org/apache/qpid/stac/ConnectionTest.java b/java/management/cli/test/org/apache/qpid/stac/ConnectionTest.java deleted file mode 100644 index 247fea6d31..0000000000 --- a/java/management/cli/test/org/apache/qpid/stac/ConnectionTest.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ -package org.apache.qpid.stac; - -import org.apache.qpid.management.jmx.AMQConsole; -import org.apache.qpid.stac.jmx.MBeanServerConnectionContext; - -public class ConnectionTest -{ - public static void main(String[] args) throws Exception - { - - AMQConsole console = new AMQConsole("localhost", 5672, "guest", "guest", "/test"); - console.initialise(); - console.registerAllMBeans(); - MBeanServerConnectionContext connectionContext = new MBeanServerConnectionContext(); - connectionContext.connect(); - connectionContext.ls(); - } -} |