Author: aco
Date: Wed Dec 21 01:31:18 2005
New Revision: 358241
URL: http://svn.apache.org/viewcvs?rev=358241&view=rev
Log:
Added a basic mean to query the jmx context. Performed a little code
restructuring and bug fixing. Type "query --help" for details.
Added:
incubator/activemq/trunk/assembly/src/release/bin/query
incubator/activemq/trunk/assembly/src/release/bin/query.bat
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/Main.java
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/Main.java
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/Main.java?rev=358241&r1=358240&r2=358241&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/Main.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/Main.java
Wed Dec 21 01:31:18 2005
@@ -24,13 +24,9 @@
import javax.management.MBeanServerConnection;
import javax.management.ObjectName;
import javax.management.ObjectInstance;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Iterator;
-import java.util.Set;
-import java.util.Map;
-import java.util.HashMap;
+import javax.management.MBeanAttributeInfo;
+import java.util.*;
+import java.util.concurrent.CopyOnWriteArraySet;
import java.io.File;
import java.net.MalformedURLException;
import java.net.URL;
@@ -54,24 +50,27 @@
public static final int HELP_STOP_BROKER = 2;
public static final int HELP_LIST_BROKER = 3;
public static final int HELP_STAT_BROKER = 4;
+ public static final int HELP_QUERY_BROKER = 5;
- public static final int TASK_NONE = -1;
- public static final int TASK_START_BROKER = 0;
- public static final int TASK_STOP_BROKER = 1;
- public static final int TASK_LIST_BROKER = 2;
- public static final int TASK_STAT_BROKER = 3;
- public static final int TASK_PRINT_MAIN_HELP = 4;
- public static final int TASK_PRINT_START_HELP = 5;
- public static final int TASK_PRINT_STOP_HELP = 6;
- public static final int TASK_PRINT_LIST_HELP = 7;
- public static final int TASK_PRINT_STAT_HELP = 8;
- public static final int TASK_PRINT_ALL_HELP = 9;
- public static final int TASK_PRINT_VER = 10;
-
- private static final String BROKER_FACTORY_CLASS =
"org.activemq.broker.BrokerFactory";
- private static final String DEFAULT_CONFIG_URI = "xbean:activemq.xml";
- private static final String DEFAULT_JMX_URL =
"service:jmx:rmi:///jndi/rmi://localhost:1099/jmxconnector";
- private static final String DEFAULT_JMX_DOMAIN = "org.activemq";
+ public static final int TASK_NONE = 0;
+ public static final int TASK_START_BROKER = 1;
+ public static final int TASK_STOP_BROKER = 2;
+ public static final int TASK_LIST_BROKER = 3;
+ public static final int TASK_STAT_BROKER = 4;
+ public static final int TASK_QUERY_BROKER = 5;
+ public static final int TASK_PRINT_MAIN_HELP = 6;
+ public static final int TASK_PRINT_START_HELP = 7;
+ public static final int TASK_PRINT_STOP_HELP = 8;
+ public static final int TASK_PRINT_LIST_HELP = 9;
+ public static final int TASK_PRINT_STAT_HELP = 10;
+ public static final int TASK_PRINT_QUERY_HELP = 11;
+ public static final int TASK_PRINT_ALL_HELP = 12;
+ public static final int TASK_PRINT_VER = 13;
+
+ public static final String BROKER_FACTORY_CLASS =
"org.activemq.broker.BrokerFactory";
+ public static final String DEFAULT_CONFIG_URI = "xbean:activemq.xml";
+ public static final String DEFAULT_JMX_URL =
"service:jmx:rmi:///jndi/rmi://localhost:1099/jmxconnector";
+ public static final String DEFAULT_JMX_DOMAIN = "org.activemq";
private static final String DEFAULT_KEY_BROKER_NAME = "BrokerName";
private static final String DEFAULT_METHOD_BROKER_STOP = "terminateJVM";
@@ -91,7 +90,22 @@
private static final int STAT_DISP_BROKER = Integer.parseInt("0001", 2);
private static final int STAT_DISP_ALL = Integer.parseInt("1111", 2);
- private final ArrayList extensions = new ArrayList();
+ // Query object type to id mapping
+ private static final Properties QUERY_TYPE_ID_MAP = new Properties();
+
+ static
+ {
+ QUERY_TYPE_ID_MAP.setProperty("Broker", "BrokerName");
+ QUERY_TYPE_ID_MAP.setProperty("Connection", "Connection");
+ QUERY_TYPE_ID_MAP.setProperty("Connector", "ConnectorName");
+ QUERY_TYPE_ID_MAP.setProperty("NetworkConnector", "BrokerName");
+ QUERY_TYPE_ID_MAP.setProperty("Queue", "Destination");
+ QUERY_TYPE_ID_MAP.setProperty("Topic", "Destination");
+ };
+
+ private final ArrayList extensions = new ArrayList();
+ private final Map queryObjects = new HashMap();
+ private final List queryViews = new ArrayList();
private int taskType = TASK_NONE;
private boolean stopAll = false;
@@ -147,6 +161,14 @@
}
break;
+ case TASK_QUERY_BROKER:
+ try {
+ app.taskQueryBrokers();
+ } catch (Throwable e) {
+ System.out.println("Failed to query broker. Reason: " +
e.getMessage());
+ }
+ break;
+
case TASK_PRINT_MAIN_HELP:
app.printHelp(HELP_MAIN_APP);
break;
@@ -167,6 +189,10 @@
app.printHelp(HELP_STAT_BROKER);
break;
+ case TASK_PRINT_QUERY_HELP:
+ app.printHelp(HELP_QUERY_BROKER);
+ break;
+
case TASK_PRINT_VER:
app.printVersion();
break;
@@ -181,6 +207,198 @@
}
}
+ public int parseTask(List tokens) {
+ if (tokens.isEmpty()) {
+ // If no defined arguments, assume start task and default uri
+ return TASK_START_BROKER;
+ }
+
+ // Process task token
+ String taskToken = (String)tokens.get(0);
+
+ if (taskToken.equals("start")) {
+ tokens.remove(0);
+ return TASK_START_BROKER;
+ } else if (taskToken.equals("stop")) {
+ tokens.remove(0);
+ return TASK_STOP_BROKER;
+ } else if (taskToken.equals("list")) {
+ tokens.remove(0);
+ return TASK_LIST_BROKER;
+ } else if (taskToken.equals("stat")) {
+ tokens.remove(0);
+ return TASK_STAT_BROKER;
+ } else if (taskToken.equals("query")) {
+ tokens.remove(0);
+ return TASK_QUERY_BROKER;
+ } else if (taskToken.equals("-h") || taskToken.equals("-?") ||
taskToken.equals("--help")) {
+ // No need to parse other tokens
+ tokens.clear();
+ return TASK_PRINT_MAIN_HELP;
+ } else if (taskToken.equals("--version")) {
+ // No need to parse other tokens
+ tokens.clear();
+ return TASK_PRINT_VER;
+ } else {
+ // If not a valid task, assume start task and succeeding args are
options
+ return TASK_START_BROKER;
+ }
+ }
+
+ public void parseOptions(List tokens) {
+ String token;
+
+ while (!tokens.isEmpty()) {
+ token = (String)tokens.get(0);
+
+ // If token is an option
+ if (token.startsWith("-")) {
+
+ // Consider token to be processed
+ tokens.remove(0);
+
+ // If token is a help option
+ if (token.equals("-h") || token.equals("-?") ||
token.equals("--help")) {
+ switch (this.getTaskType()) {
+ case TASK_STOP_BROKER:
+ this.setTaskType(TASK_PRINT_STOP_HELP);
+ tokens.clear();
+ return;
+
+ case TASK_LIST_BROKER:
+ this.setTaskType(TASK_PRINT_LIST_HELP);
+ tokens.clear();
+ return;
+
+ case TASK_STAT_BROKER:
+ this.setTaskType(TASK_PRINT_STAT_HELP);
+ tokens.clear();
+ return;
+
+ case TASK_QUERY_BROKER:
+ this.setTaskType(TASK_PRINT_QUERY_HELP);
+ tokens.clear();
+ return;
+
+ case TASK_START_BROKER:
+ default:
+ this.setTaskType(TASK_PRINT_START_HELP);
+ tokens.clear();
+ return;
+
+ }
+
+ // If token is a version option
+ } else if (token.equals("--version")) {
+ this.setTaskType(TASK_PRINT_VER);
+ tokens.clear();
+ return;
+
+ // If token is an extension dir option
+ } else if (token.equals("--extdir")) {
+ if(!canUseExtdir()) {
+ printError("Extension directory feature not available
due to the system classpath being able to load: " + BROKER_FACTORY_CLASS);
+ tokens.clear();
+ return;
+ }
+
+ // If no extension directory is specified, or next token
is another option
+ if (tokens.isEmpty() ||
((String)tokens.get(0)).startsWith("-")) {
+ printError("Extension directory not specified.");
+ return;
+ }
+
+ // Process extension dir token
+ File extDir = new File((String)tokens.remove(0));
+ if (!extDir.isDirectory()) {
+ printError("Extension directory specified is not valid
directory: " + extDir);
+ return;
+ }
+
+ this.addExtensionDirectory(extDir);
+ }
+
+ // If token is a system property define option
+ else if (token.startsWith("-D")) {
+ String key = token.substring(2);
+ String value = "";
+ int pos = key.indexOf("=");
+ if (pos >= 0) {
+ value = key.substring(pos + 1);
+ key = key.substring(0, pos);
+ }
+ System.setProperty(key, value);
+ }
+
+ // If token is a query define option
+ else if (token.startsWith("-Q")) {
+ String key = token.substring(2);
+ String value = "";
+ int pos = key.indexOf("=");
+ if (pos >= 0) {
+ value = key.substring(pos + 1);
+ key = key.substring(0, pos);
+ }
+
+ queryObjects.put(key, value);
+ }
+
+ // If token is a view option
+ else if (token.startsWith("--view")) {
+
+ // If no view specified, or next token is a new option
+ if (tokens.isEmpty() ||
((String)tokens.get(0)).startsWith("-")) {
+ printError("Attributes to view not specified");
+ return;
+ }
+
+ // Add the attributes to view
+ Enumeration viewTokens = new
StringTokenizer((String)tokens.remove(0), ",", false);
+ while (viewTokens.hasMoreElements()) {
+ queryViews.add(viewTokens.nextElement());
+ }
+ }
+
+ // If token is a JMX URL option
+ else if (token.startsWith("--jmxurl")) {
+
+ // If no jmx url specified, or next token is a new option
+ if (tokens.isEmpty() ||
((String)tokens.get(0)).startsWith("-")) {
+ printError("JMX URL not specified.");
+ return;
+ }
+
+ // If jmx url already specified
+ if (getJmxUrl() != null) {
+ printError("Multiple JMX URL cannot be specified.");
+ tokens.clear();
+ return;
+ }
+
+ String strJmxUrl = (String)tokens.remove(0);
+ try {
+ this.setJmxUrl(new JMXServiceURL(strJmxUrl));
+ } catch (MalformedURLException e) {
+ printError("Invalid JMX URL format: " + strJmxUrl);
+ tokens.clear();
+ return;
+ }
+
+ // If token is stop all broker option
+ } else if (token.equals("--all")) {
+ this.setStopAllBrokers(true);
+
+ } else {
+ System.out.println("Ignoring unrecognized option: " +
token);
+ }
+
+ // Finish parsing options
+ } else {
+ return;
+ }
+ }
+ }
+
protected void taskStartBrokers(List brokerURIs) throws Throwable {
// Flag an error if there are multiple configuration uris
@@ -228,16 +446,18 @@
// Stop all brokers
if (this.isStopAllBrokers()) {
- JMXConnector jmxConnector = JMXConnectorFactory.connect(jmxUrl);
+ JMXConnector jmxConnector =
JMXConnectorFactory.connect(this.getJmxUrl());
MBeanServerConnection server =
jmxConnector.getMBeanServerConnection();
ObjectName brokerObjName = new ObjectName(DEFAULT_JMX_DOMAIN +
":Type=Broker,*");
this.stopBroker(server, brokerObjName);
- jmxConnector.close();
brokerNames.clear();
+ // Maybe no need to close, since context is already closed by
broker
+ //jmxConnector.close();
+
return;
}
@@ -262,7 +482,7 @@
} else {
Iterator brokerIter = brokerList.iterator();
- JMXConnector jmxConnector =
JMXConnectorFactory.connect(jmxUrl);
+ JMXConnector jmxConnector =
JMXConnectorFactory.connect(this.getJmxUrl());
MBeanServerConnection server =
jmxConnector.getMBeanServerConnection();
this.stopBroker(server,
((ObjectInstance)brokerIter.next()).getObjectName());
@@ -276,7 +496,7 @@
// Stop each specified broker
String brokerName;
- JMXConnector jmxConnector = JMXConnectorFactory.connect(jmxUrl);
+ JMXConnector jmxConnector =
JMXConnectorFactory.connect(this.getJmxUrl());
MBeanServerConnection server = jmxConnector.getMBeanServerConnection();
while (!brokerNames.isEmpty()) {
@@ -324,7 +544,7 @@
} else {
Iterator brokerIter = brokerList.iterator();
- JMXConnector jmxConnector =
JMXConnectorFactory.connect(jmxUrl);
+ JMXConnector jmxConnector =
JMXConnectorFactory.connect(this.getJmxUrl());
MBeanServerConnection server =
jmxConnector.getMBeanServerConnection();
ObjectName brokerObjName =
((ObjectInstance)brokerIter.next()).getObjectName();
@@ -338,7 +558,7 @@
// Print the statistics for each specified broker
String brokerName;
- JMXConnector jmxConnector = JMXConnectorFactory.connect(jmxUrl);
+ JMXConnector jmxConnector =
JMXConnectorFactory.connect(this.getJmxUrl());
MBeanServerConnection server = jmxConnector.getMBeanServerConnection();
while (!brokerNames.isEmpty()) {
@@ -351,152 +571,47 @@
jmxConnector.close();
}
- public int parseTask(List tokens) {
- if (tokens.isEmpty()) {
- // If no defined arguments, assume start task and default uri
- return TASK_START_BROKER;
- }
-
- // Process task token
- String taskToken = (String)tokens.get(0);
-
- if (taskToken.equals("start")) {
- tokens.remove(0);
- return TASK_START_BROKER;
- } else if (taskToken.equals("stop")) {
- tokens.remove(0);
- return TASK_STOP_BROKER;
- } else if (taskToken.equals("list")) {
- tokens.remove(0);
- return TASK_LIST_BROKER;
- } else if (taskToken.equals("stat")) {
- tokens.remove(0);
- return TASK_STAT_BROKER;
- } else if (taskToken.equals("-h") || taskToken.equals("-?") ||
taskToken.equals("--help")) {
- // No need to parse other tokens
- tokens.clear();
- return TASK_PRINT_MAIN_HELP;
- } else if (taskToken.equals("--version")) {
- // No need to parse other tokens
- tokens.clear();
- return TASK_PRINT_VER;
- } else {
- // If not a valid task, assume start task and succeeding args are
options
- return TASK_START_BROKER;
+ protected void taskQueryBrokers() throws Throwable {
+ // Check if there is a user-specified JMX URL
+ if (this.getJmxUrl() == null) {
+ this.setJmxUrl(this.getDefaultJmxUrl());
}
- }
-
- public void parseOptions(List tokens) {
- String token;
- while (!tokens.isEmpty()) {
- token = (String)tokens.get(0);
-
- // If token is an option
- if (token.startsWith("-")) {
-
- // Consider token to be processed
- tokens.remove(0);
-
- // If token is a help option
- if (token.equals("-h") || token.equals("-?") ||
token.equals("--help")) {
- switch (this.getTaskType()) {
- case TASK_STOP_BROKER:
- this.setTaskType(TASK_PRINT_STOP_HELP);
- tokens.clear();
- return;
-
- case TASK_LIST_BROKER:
- this.setTaskType(TASK_PRINT_LIST_HELP);
- tokens.clear();
- return;
-
- case TASK_STAT_BROKER:
- this.setTaskType(TASK_PRINT_STAT_HELP);
- tokens.clear();
- return;
-
- case TASK_START_BROKER:
- default:
- this.setTaskType(TASK_PRINT_START_HELP);
- tokens.clear();
- return;
-
- }
-
- // If token is a version option
- } else if (token.equals("--version")) {
- this.setTaskType(TASK_PRINT_VER);
- tokens.clear();
- return;
-
- // If token is an extension dir option
- } else if (token.equals("--extdir")) {
- if(!canUseExtdir()) {
- printError("Extension directory feature not available
due to the system classpath being able to load: " + BROKER_FACTORY_CLASS);
- tokens.clear();
- return;
- }
-
- if (tokens.isEmpty()) {
- printError("Extension directory not specified.");
- return;
- }
-
- // Process extension dir token
- File extDir = new File((String)tokens.remove(0));
- if (!extDir.isDirectory()) {
- printError("Extension directory specified is not valid
directory: " + extDir);
- return;
- }
-
- this.addExtensionDirectory(extDir);
- }
-
- // If token is a system property define option
- else if (token.startsWith("-D")) {
- String key = token.substring(2);
- String value = "";
- int pos = key.indexOf("=");
- if (pos >= 0) {
- value = key.substring(pos + 1);
- key = key.substring(0, pos);
- }
- System.setProperty(key, value);
- }
-
- // If token is a JMX URL option
- else if (token.startsWith("--jmxurl")) {
- if (tokens.isEmpty()) {
- printError("JMX URL not specified.");
- return;
- }
-
- if (getJmxUrl() != null) {
- printError("Multiple JMX URL cannot be specified.");
- tokens.clear();
- return;
- }
+ JMXConnector jmxConnector =
JMXConnectorFactory.connect(this.getJmxUrl());
+ MBeanServerConnection server = jmxConnector.getMBeanServerConnection();
- String strJmxUrl = (String)tokens.remove(0);
- try {
- this.setJmxUrl(new JMXServiceURL(strJmxUrl));
- } catch (MalformedURLException e) {
- printError("Invalid JMX URL format: " + strJmxUrl);
- tokens.clear();
- return;
- }
+ Set mbeans;
+ // If there is no query defined get all mbeans
+ if (this.getQueryObjects().isEmpty()) {
+ ObjectName queryName = new ObjectName(DEFAULT_JMX_DOMAIN + ":*");
- // If token is stop all broker option
- } else if (token.equals("--all")) {
- this.setStopAllBrokers(true);
+ mbeans = server.queryMBeans(queryName, null);
- // Ignore unknown options
+ // Construct the object name based on the query
+ } else {
+ mbeans = new CopyOnWriteArraySet();
+ Set queryKeys = queryObjects.keySet();
+ for (Iterator i=queryKeys.iterator(); i.hasNext();) {
+ String objType = (String)i.next();
+ String objName = (String)queryObjects.get(objType);
+
+ // If select all type
+ ObjectName queryName;
+ if (objName.equals("*")) {
+ queryName = new ObjectName(DEFAULT_JMX_DOMAIN + ":Type=" +
objType + ",*");
} else {
- System.out.println("Ignoring unrecognized option: " +
token);
+ queryName = new ObjectName(DEFAULT_JMX_DOMAIN + ":Type=" +
objType + "," +
+
QUERY_TYPE_ID_MAP.getProperty(objType) + "=" + objName + ",*");
}
+ mbeans.addAll(server.queryMBeans(queryName, null));
}
}
+
+ for (Iterator i=mbeans.iterator(); i.hasNext();) {
+ printMBeanAttr(server, (ObjectInstance)i.next(),
this.getQueryViews());
+ }
+
+ jmxConnector.close();
}
public void addExtensionDirectory(File directory) {
@@ -604,6 +719,54 @@
}
}
+ public void printMBeanAttr(MBeanServerConnection server, ObjectInstance
mbean, List attrView) {
+ ObjectName mbeanObjName = mbean.getObjectName();
+ String mbeanType = mbeanObjName.getKeyProperty("Type");
+ String mbeanName =
mbeanObjName.getKeyProperty(QUERY_TYPE_ID_MAP.getProperty(mbeanType));
+ System.out.println("MBean Type: " + mbeanType);
+ System.out.println("MBean Name: " + mbeanName);
+ System.out.println("MBean Attributes:");
+
+ try {
+ MBeanAttributeInfo[] attrs =
server.getMBeanInfo(mbeanObjName).getAttributes();
+
+ // If there mbean has no attribute, print a no attribute message
+ if (attrs.length == 0) {
+ System.out.println(" MBean has no attributes.");
+ System.out.println();
+ return;
+ }
+
+ // If there is no view specified, print all attributes
+ if (attrView == null || attrView.isEmpty()) {
+ for (int i=0; i<attrs.length; i++) {
+ Object attrVal = server.getAttribute(mbeanObjName,
attrs[i].getName());
+ System.out.println(" " + attrs[i].getName() + " = " +
attrVal.toString());
+ }
+ System.out.println();
+ return;
+ }
+
+ // Print attributes specified by view
+ boolean matchedAttr = false;
+ for (int i=0; i<attrs.length; i++) {
+ if (attrView.contains(attrs[i].getName())) {
+ matchedAttr = true;
+ Object attrVal = server.getAttribute(mbeanObjName,
attrs[i].getName());
+ System.out.println(" " + attrs[i].getName() + " = " +
attrVal.toString());
+ }
+ }
+
+ // If the mbean's attributes did not match any of the view,
display a message
+ if (!matchedAttr) {
+ System.out.println(" View did not match any of the mbean's
attributes.");
+ }
+ System.out.println();
+ } catch (Exception e) {
+ System.out.println("Failed to print mbean attributes. Reason: " +
e.getMessage());
+ }
+ }
+
public void printBrokerStat(String brokerName, Map brokerStat) {
printBrokerStat(brokerName, brokerStat, STAT_DISP_ALL);
}
@@ -678,6 +841,14 @@
return stopAll;
}
+ public Map getQueryObjects() {
+ return queryObjects;
+ }
+
+ public List getQueryViews() {
+ return queryViews;
+ }
+
public ClassLoader getClassLoader() throws MalformedURLException {
if(classLoader==null) {
//
@@ -818,10 +989,10 @@
"Task Usage: Main start [start-options] [uri]",
"",
"Start Options:",
- " --extdir dir Add the jar files in the directory to the
classpath.",
- " -Dname=value Define a system property.",
- " --version Display the version information.",
- " -h,-?,--help Display the start broker help information.",
+ " --extdir <dir> Add the jar files in the directory to
the classpath.",
+ " -D<name>=<value> Define a system property.",
+ " --version Display the version information.",
+ " -h,-?,--help Display the start broker help
information.",
"",
"URI:",
"",
@@ -846,10 +1017,10 @@
"Task Usage: Main stop [stop-options] [broker-name1]
[broker-name2] ...",
"",
"Stop Options:",
- " --jmxurl url Set the JMX URL to connect to.",
- " --all Stop all brokers.",
- " --version Display the version information.",
- " -h,-?,--help Display the stop broker help information.",
+ " --jmxurl <url> Set the JMX URL to connect to.",
+ " --all Stop all brokers.",
+ " --version Display the version information.",
+ " -h,-?,--help Display the stop broker help
information.",
"",
"Broker Names:",
" Name of the brokers that will be stopped.",
@@ -863,9 +1034,9 @@
"Task Usage: Main list [list-options]",
"",
"List Options:",
- " --jmxurl url Set the JMX URL to connect to.",
- " --version Display the version information.",
- " -h,-?,--help Display the stop broker help information.",
+ " --jmxurl <url> Set the JMX URL to connect to.",
+ " --version Display the version information.",
+ " -h,-?,--help Display the stop broker help
information.",
"",
},
@@ -874,10 +1045,42 @@
"Task Usage: Main stat [stat-options] [broker-name1]
[broker-name2] ...",
"",
"Stat Options:",
- " --jmxurl url Set the JMX URL to connect to.",
- " --version Display the version information.",
- " -h,-?,--help Display the stop broker help information.",
+ " --jmxurl <url> Set the JMX URL to connect to.",
+ " --version Display the version information.",
+ " -h,-?,--help Display the stat broker help
information.",
"",
+ },
+
+ // Query brokers task help
+ {
+ "Task Usage: Main query [query-options]",
+ "",
+ "Query Options:",
+ " -Q<type>=<name> Filter the specific object type
using the defined object identifier.",
+ " --view <attr1>,<attr2>,... Select the specific attribute
of the object to view. By default all attributes will be displayed.",
+ " --jmxurl <url> Set the JMX URL to connect to.",
+ " --version Display the version
information.",
+ " -h,-?,--help Display the query broker help
information.",
+ "",
+ "Examples:",
+ " Main query",
+ " - Print all the attributes of all registered objects
(queues, topics, connections, etc).",
+ "",
+ " Main query -QQueue=TEST.FOO",
+ " - Print all the attributes of the queue with destination
name TEST.FOO.",
+ "",
+ " Main query -QTopic=*",
+ " - Print all the attributes of all registered topics.",
+ "",
+ " Main query --view EnqueueCount,DequeueCount",
+ " - Print the attributes EnqueueCount and DequeueCount of
all registered objects.",
+ "",
+ " Main -QTopic=* --view EnqueueCount,DequeueCount",
+ " - Print the attributes EnqueueCount and DequeueCount of
all registered topics.",
+ "",
+ " Main -QTopic=* -QQueue=* --view EnqueueCount,DequeueCount",
+ " - Print the attributes EnqueueCount and DequeueCount of
all registered topics and queues.",
+ ""
}
};
}
Added: incubator/activemq/trunk/assembly/src/release/bin/query
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/assembly/src/release/bin/query?rev=358241&view=auto
==============================================================================
--- incubator/activemq/trunk/assembly/src/release/bin/query (added)
+++ incubator/activemq/trunk/assembly/src/release/bin/query Wed Dec 21 01:31:18
2005
@@ -0,0 +1,133 @@
+#!/bin/sh
+
+# ActiveMQ shell script
+#
+# $Id: activemq,v 1.1.1.1 2005/03/11 21:14:04 jstrachan Exp $
+#
+# This script is heavily based on the Ant script
+#
+# Copyright (c) 2001-2003 The Apache Software Foundation. All rights
+# reserved.
+
+# load system-wide activemq configuration
+if [ -f "/etc/activemq.conf" ] ; then
+ . /etc/activemq.conf
+fi
+
+# provide default values for people who don't use RPMs
+if [ -z "$usejikes" ] ; then
+ usejikes=false;
+fi
+
+# load user activemq configuration
+if [ -f "$HOME/.activemqrc" ] ; then
+ . "$HOME/.activemqrc"
+fi
+
+# OS specific support. $var _must_ be set to either true or false.
+cygwin=false;
+darwin=false;
+case "`uname`" in
+ CYGWIN*) cygwin=true ;;
+ Darwin*) darwin=true
+ if [ -z "$JAVA_HOME" ] ; then
+ JAVA_HOME=/System/Library/Frameworks/JavaVM.framework/Home
+ fi
+ ;;
+esac
+
+if [ -z "$ACTIVEMQ_HOME" ] ; then
+ # try to find ACTIVEMQ
+ if [ -d /opt/activemq ] ; then
+ ACTIVEMQ_HOME=/opt/activemq
+ fi
+
+ if [ -d "${HOME}/opt/activemq" ] ; then
+ ACTIVEMQ_HOME="${HOME}/opt/activemq"
+ fi
+
+ ## resolve links - $0 may be a link to activemq's home
+ PRG="$0"
+ progname=`basename "$0"`
+ saveddir=`pwd`
+
+ # need this for relative symlinks
+ dirname_prg=`dirname "$PRG"`
+ cd "$dirname_prg"
+
+ while [ -h "$PRG" ] ; do
+ ls=`ls -ld "$PRG"`
+ link=`expr "$ls" : '.*-> \(.*\)$'`
+ if expr "$link" : '.*/.*' > /dev/null; then
+ PRG="$link"
+ else
+ PRG=`dirname "$PRG"`"/$link"
+ fi
+ done
+
+ ACTIVEMQ_HOME=`dirname "$PRG"`/..
+
+ cd "$saveddir"
+
+ # make it fully qualified
+ ACTIVEMQ_HOME=`cd "$ACTIVEMQ_HOME" && pwd`
+fi
+
+# For Cygwin, ensure paths are in UNIX format before anything is touched
+if $cygwin ; then
+ [ -n "$ACTIVEMQ_HOME" ] &&
+ ACTIVEMQ_HOME=`cygpath --unix "$ACTIVEMQ_HOME"`
+ [ -n "$JAVA_HOME" ] &&
+ JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
+ [ -n "$CLASSPATH" ] &&
+ CLASSPATH=`cygpath --path --unix "$CLASSPATH"`
+fi
+
+if [ -z "$JAVACMD" ] ; then
+ if [ -n "$JAVA_HOME" ] ; then
+ if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+ # IBM's JDK on AIX uses strange locations for the executables
+ JAVACMD="$JAVA_HOME/jre/sh/java"
+ else
+ JAVACMD="$JAVA_HOME/bin/java"
+ fi
+ else
+ JAVACMD=`which java 2> /dev/null `
+ if [ -z "$JAVACMD" ] ; then
+ JAVACMD=java
+ fi
+ fi
+fi
+
+if [ ! -x "$JAVACMD" ] ; then
+ echo "Error: JAVA_HOME is not defined correctly."
+ echo " We cannot execute $JAVACMD"
+ exit 1
+fi
+
+# For Cygwin, switch paths to Windows format before running java
+if $cygwin; then
+ ACTIVEMQ_HOME=`cygpath --windows "$ACTIVEMQ_HOME"`
+ JAVA_HOME=`cygpath --windows "$JAVA_HOME"`
+ CLASSPATH=`cygpath --path --windows "$CLASSPATH"`
+ CYGHOME=`cygpath --windows "$HOME"`
+fi
+
+
+if [ -n "ACTIVEMQ_OPTS" ] ; then
+ ACTIVEMQ_OPTS="-Xmx512M -Dderby.system.home=../data
-Dderby.storage.fileSyncTransactionLog=true"
+fi
+
+# Uncomment to enable YourKit profiling
+#ACTIVEMQ_DEBUG_OPTS="-Xrunyjpagent"
+
+# Uncomment to enable remote debugging
+#ACTIVEMQ_DEBUG_OPTS="-Xdebug -Xnoagent -Djava.compiler=NONE
-Xrunjdwp:transport=dt_socket,server=y,suspend=n,address=5005"
+
+ACTIVEMQ_TASK="query"
+if [ -n "$CYGHOME" ]; then
+ exec "$JAVACMD" $ACTIVEMQ_DEBUG_OPTS $ACTIVEMQ_OPTS -classpath ""
-Dactivemq.home="${ACTIVEMQ_HOME}" -Dcygwin.user.home="$CYGHOME" -jar
${ACTIVEMQ_HOME}/bin/run.jar $ACTIVEMQ_TASK $@
+else
+ exec "$JAVACMD" $ACTIVEMQ_DEBUG_OPTS $ACTIVEMQ_OPTS -classpath ""
-Dactivemq.home="${ACTIVEMQ_HOME}" -jar ${ACTIVEMQ_HOME}/bin/run.jar
$ACTIVEMQ_TASK $@
+fi
+
Added: incubator/activemq/trunk/assembly/src/release/bin/query.bat
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/assembly/src/release/bin/query.bat?rev=358241&view=auto
==============================================================================
--- incubator/activemq/trunk/assembly/src/release/bin/query.bat (added)
+++ incubator/activemq/trunk/assembly/src/release/bin/query.bat Wed Dec 21
01:31:18 2005
@@ -0,0 +1,106 @@
[EMAIL PROTECTED] off
+
+REM ActiveMQ shell script
+REM
+REM $Id: shutdown.bat,v 1.1.1.1 2005/12/09 21:14:04 aco Exp $
+REM
+REM This script is heavily based on the Ant script
+REM
+REM Copyright (c) 2001-2003 The Apache Software Foundation. All rights
+REM reserved.
+
+if exist "%HOME%\activemqrc_pre.bat" call "%HOME%\activemqrc_pre.bat"
+
+if "%OS%"=="Windows_NT" @setlocal
+
+rem %~dp0 is expanded pathname of the current script under NT
+set DEFAULT_ACTIVEMQ_HOME=%~dp0..
+
+if "%ACTIVEMQ_HOME%"=="" set ACTIVEMQ_HOME=%DEFAULT_ACTIVEMQ_HOME%
+set DEFAULT_ACTIVEMQ_HOME=
+
+rem Slurp the command line arguments. This loop allows for an unlimited number
+rem of arguments (up to the command line limit, anyway).
+set ACTIVEMQ_CMD_LINE_ARGS=%1
+if ""%1""=="""" goto doneStart
+shift
+:setupArgs
+if ""%1""=="""" goto doneStart
+set ACTIVEMQ_CMD_LINE_ARGS=%ACTIVEMQ_CMD_LINE_ARGS% %1
+shift
+goto setupArgs
+rem This label provides a place for the argument list loop to break out
+rem and for NT handling to skip to.
+
+:doneStart
+rem find ACTIVEMQ_HOME if it does not exist due to either an invalid value
passed
+rem by the user or the %0 problem on Windows 9x
+if exist "%ACTIVEMQ_HOME%\README.txt" goto checkJava
+
+rem check for activemq in Program Files on system drive
+if not exist "%SystemDrive%\Program Files\activemq" goto checkSystemDrive
+set ACTIVEMQ_HOME=%SystemDrive%\Program Files\activemq
+goto checkJava
+
+:checkSystemDrive
+rem check for activemq in root directory of system drive
+if not exist %SystemDrive%\activemq\README.txt goto checkCDrive
+set ACTIVEMQ_HOME=%SystemDrive%\activemq
+goto checkJava
+
+:checkCDrive
+rem check for activemq in C:\activemq for Win9X users
+if not exist C:\activemq\README.txt goto noAntHome
+set ACTIVEMQ_HOME=C:\activemq
+goto checkJava
+
+:noAntHome
+echo ACTIVEMQ_HOME is set incorrectly or activemq could not be located. Please
set ACTIVEMQ_HOME.
+goto end
+
+:checkJava
+set _JAVACMD=%JAVACMD%
+set LOCALCLASSPATH=%CLASSPATH%
+
+set
JAVA_EXT_DIRS=%JAVA_HOME%\lib\ext;%ACTIVEMQ_HOME%;%ACTIVEMQ_HOME%\lib;%ACTIVEMQ_HOME%\lib\optional
+
+if "%JAVA_HOME%" == "" goto noJavaHome
+if not exist "%JAVA_HOME%\bin\java.exe" goto noJavaHome
+if "%_JAVACMD%" == "" set _JAVACMD=%JAVA_HOME%\bin\java.exe
+goto runAnt
+
+:noJavaHome
+if "%_JAVACMD%" == "" set _JAVACMD=java.exe
+echo.
+echo Warning: JAVA_HOME environment variable is not set.
+echo.
+
+:runAnt
+
+if "%ACTIVEMQ_OPTS%" == "" set ACTIVEMQ_OPTS=-Xmx512M
-Dderby.system.home="..\data" -Dderby.storage.fileSyncTransactionLog=true
+
+REM Uncomment to enable YourKit profiling
+REM SET ACTIVEMQ_DEBUG_OPTS="-Xrunyjpagent"
+
+REM Uncomment to enable remote debugging
+REM SET ACTIVEMQ_DEBUG_OPTS=-Xdebug -Xnoagent -Djava.compiler=NONE
-Xrunjdwp:transport=dt_socket,server=y,suspend=n,address=5005
+
+set LOCALCLASSPATH=%ACTIVEMQ_HOME%\conf;%LOCALCLASSPATH%
+
+set ACTIVEMQ_TASK="query"
+"%_JAVACMD%" %ACTIVEMQ_DEBUG_OPTS% %ACTIVEMQ_OPTS%
-Djava.ext.dirs="%JAVA_EXT_DIRS%" -classpath "%LOCALCLASSPATH%" -jar
%ACTIVEMQ_HOME%/bin/run.jar %ACTIVEMQ_TASK% %ACTIVEMQ_CMD_LINE_ARGS%
+
+
+goto end
+
+
+:end
+set LOCALCLASSPATH=
+set _JAVACMD=
+set ACTIVEMQ_CMD_LINE_ARGS=
+
+if "%OS%"=="Windows_NT" @endlocal
+
+:mainEnd
+if exist "%HOME%\activemqrc_post.bat" call "%HOME%\activemqrc_post.bat"
+
