Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AMQ-4760: Added dstat command to activemq karaf commands.

This commit is contained in:
Claus Ibsen 2013-10-01 16:19:19 +02:00
parent a80a1857d0
commit ee8b51b27b
2 changed files with 151 additions and 125 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
activemq-console/src/main/java/org/apache/activemq/console/command/DstatCommand.java
View File

@ -81,13 +81,13 @@ public class DstatCommand extends AbstractJmxCommand {
} }
} }
private void displayAllDestinations() throws IOException, Exception { private void displayAllDestinations() throws Exception {
String query = JmxMBeansUtil.createQueryString(queryString, "*"); String query = JmxMBeansUtil.createQueryString(queryString, "*");
List<?> queueList = JmxMBeansUtil.queryMBeans(createJmxConnection(), query); List<?> queueList = JmxMBeansUtil.queryMBeans(createJmxConnection(), query);
final String header = "%20s %10s %10s %10s %10s"; final String header = "%-60s %10s %10s %10s %10s";
final String tableRow = "%20s %10d %10d %10d %10d"; final String tableRow = "%-60s %10d %10d %10d %10d";
context.print(String.format(Locale.US, header, "Name", "Pending", "Consumers", "Enqueued", "Dequeued")); context.print(String.format(Locale.US, header, "Name", "Pending", "Consumers", "Enqueued", "Dequeued"));
@ -106,13 +106,13 @@ public class DstatCommand extends AbstractJmxCommand {
} }
} }
private void displayQueueStats() throws IOException, Exception { private void displayQueueStats() throws Exception {
String query = JmxMBeansUtil.createQueryString(queryString, "Queue"); String query = JmxMBeansUtil.createQueryString(queryString, "Queue");
List<?> queueList = JmxMBeansUtil.queryMBeans(createJmxConnection(), query); List<?> queueList = JmxMBeansUtil.queryMBeans(createJmxConnection(), query);
final String header = "%20s %10s %10s %10s %10s"; final String header = "%-60s %10s %10s %10s %10s";
final String tableRow = "%20s %10d %10d %10d %10d"; final String tableRow = "%-60s %10d %10d %10d %10d";
context.print(String.format(Locale.US, header, "Name", "Pending", "Consumers", "Enqueued", "Dequeued")); context.print(String.format(Locale.US, header, "Name", "Pending", "Consumers", "Enqueued", "Dequeued"));
@ -131,13 +131,13 @@ public class DstatCommand extends AbstractJmxCommand {
} }
} }
private void displayTopicStats() throws IOException, Exception { private void displayTopicStats() throws Exception {
String query = JmxMBeansUtil.createQueryString(queryString, "Topic"); String query = JmxMBeansUtil.createQueryString(queryString, "Topic");
List<?> topicsList = JmxMBeansUtil.queryMBeans(createJmxConnection(), query); List<?> topicsList = JmxMBeansUtil.queryMBeans(createJmxConnection(), query);
final String header = "%20s %10s %10s %10s"; final String header = "%-60s %10s %10s %10s";
final String tableRow = "%20s %10d %10d %10d"; final String tableRow = "%-60s %10d %10d %10d";
context.print(String.format(Locale.US, header, "Name", "Consumers", "Enqueued", "Dequeued")); context.print(String.format(Locale.US, header, "Name", "Consumers", "Enqueued", "Dequeued"));

26
activemq-karaf/src/main/resources/OSGI-INF/blueprint/activemq-karaf.xml
View File

@ -150,4 +150,30 @@
</property> </property>
</bean> </bean>
<!-- ActiveMQ Dstat Command -->
<bean id="dstatcommand" class="org.apache.activemq.karaf.commands.ActiveMQCommand">
<property name="blueprintContainer" ref="blueprintContainer"/>
<property name="blueprintConverter" ref="blueprintConverter"/>
<property name="actionId" value="dstataction"/>
</bean>
<service ref="dstatcommand" activation="lazy">
<interfaces>
<value>org.apache.felix.service.command.Function</value>
<value>org.apache.karaf.shell.console.CompletableFunction</value>
</interfaces>
<service-properties>
<entry key="osgi.command.scope" value="activemq"/>
<entry key="osgi.command.function" value="dstat"/>
</service-properties>
</service>
<bean id="dstataction" class="org.apache.activemq.karaf.commands.ActiveMQCommandSupport"
activation="lazy"
scope="prototype">
<property name="command">
<bean class="org.apache.activemq.console.command.DstatCommand"/>
</property>
</bean>
</blueprint> </blueprint>