diff options
Diffstat (limited to 'qpid/java/management/cli/src')
12 files changed, 0 insertions, 1058 deletions
diff --git a/qpid/java/management/cli/src/org/apache/qpid/stac/Stac.java b/qpid/java/management/cli/src/org/apache/qpid/stac/Stac.java deleted file mode 100644 index 0ee0f842f4..0000000000 --- a/qpid/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/qpid/java/management/cli/src/org/apache/qpid/stac/StacInterpreter.java b/qpid/java/management/cli/src/org/apache/qpid/stac/StacInterpreter.java deleted file mode 100644 index 00e03ac109..0000000000 --- a/qpid/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/qpid/java/management/cli/src/org/apache/qpid/stac/commands/CdCommand.java b/qpid/java/management/cli/src/org/apache/qpid/stac/commands/CdCommand.java deleted file mode 100644 index 1a1fb7470c..0000000000 --- a/qpid/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/qpid/java/management/cli/src/org/apache/qpid/stac/commands/InvokeCommand.java b/qpid/java/management/cli/src/org/apache/qpid/stac/commands/InvokeCommand.java deleted file mode 100644 index b9728416e0..0000000000 --- a/qpid/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/qpid/java/management/cli/src/org/apache/qpid/stac/commands/LsCommand.java b/qpid/java/management/cli/src/org/apache/qpid/stac/commands/LsCommand.java deleted file mode 100644 index 6d7006a3c9..0000000000 --- a/qpid/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/qpid/java/management/cli/src/org/apache/qpid/stac/jmx/CurrentMBean.java b/qpid/java/management/cli/src/org/apache/qpid/stac/jmx/CurrentMBean.java deleted file mode 100644 index e1163bf6ce..0000000000 --- a/qpid/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/qpid/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanAttributeInfoComparator.java b/qpid/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanAttributeInfoComparator.java deleted file mode 100644 index 534b9bbb9e..0000000000 --- a/qpid/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/qpid/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanOperationInfoComparator.java b/qpid/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanOperationInfoComparator.java deleted file mode 100644 index a1a7422fe3..0000000000 --- a/qpid/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/qpid/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanServerConnectionContext.java b/qpid/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanServerConnectionContext.java deleted file mode 100644 index 300a617cd5..0000000000 --- a/qpid/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/qpid/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanUtils.java b/qpid/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanUtils.java deleted file mode 100644 index 2447322166..0000000000 --- a/qpid/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/qpid/java/management/cli/src/org/apache/qpid/stac/jmx/NotConnectedException.java b/qpid/java/management/cli/src/org/apache/qpid/stac/jmx/NotConnectedException.java deleted file mode 100644 index 1fbc1501b5..0000000000 --- a/qpid/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/qpid/java/management/cli/src/python/stac.py b/qpid/java/management/cli/src/python/stac.py deleted file mode 100644 index 6a7230d724..0000000000 --- a/qpid/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() |