[jboss-cvs] JBossAS SVN: r65511 - in trunk/messaging: src/main/org/jboss/mq/server/jmx and 1 other directory.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Thu Sep 20 18:42:14 EDT 2007
Author: clebert.suconic at jboss.com
Date: 2007-09-20 18:42:14 -0400 (Thu, 20 Sep 2007)
New Revision: 65511
Modified:
trunk/messaging/.classpath
trunk/messaging/build.xml
trunk/messaging/src/main/org/jboss/mq/server/jmx/Queue.java
trunk/messaging/src/main/org/jboss/mq/server/jmx/Topic.java
Log:
JBAS-4658 - Adding Management annotations on jms.Queue and Topic
Modified: trunk/messaging/.classpath
===================================================================
--- trunk/messaging/.classpath 2007-09-20 21:05:41 UTC (rev 65510)
+++ trunk/messaging/.classpath 2007-09-20 22:42:14 UTC (rev 65511)
@@ -12,7 +12,8 @@
<classpathentry kind="lib" path="/thirdparty/apache-log4j/lib/log4j.jar"/>
<classpathentry kind="src" path="/j2se"/>
<classpathentry combineaccessrules="false" kind="src" path="/system-jmx"/>
- <classpathentry kind="lib" path="/thirdparty/jboss/messaging/lib/jboss-messaging.jar" sourcepath="/home/svn/JBossMessaging/JBossMessaging_1_0_1_GA/src/main"/>
- <classpathentry kind="lib" path="/thirdparty/jboss/jboss-javaee/lib/jboss-javaee.jar" sourcepath="/thirdparty/jboss/jboss-javaee/lib/jboss-javaee-sources.jar"/>
+ <classpathentry sourcepath="/home/svn/JBossMessaging/JBossMessaging_1_0_1_GA/src/main" kind="lib" path="/thirdparty/jboss/messaging/lib/jboss-messaging.jar"/>
+ <classpathentry sourcepath="/thirdparty/jboss/jboss-javaee/lib/jboss-javaee-sources.jar" kind="lib" path="/thirdparty/jboss/jboss-javaee/lib/jboss-javaee.jar"/>
+ <classpathentry sourcepath="/thirdparty/jboss/microcontainer/lib/jboss-managed-sources.jar" kind="lib" path="/thirdparty/jboss/microcontainer/lib/jboss-managed.jar"/>
<classpathentry kind="output" path="output/eclipse-classes"/>
</classpath>
Modified: trunk/messaging/build.xml
===================================================================
--- trunk/messaging/build.xml 2007-09-20 21:05:41 UTC (rev 65510)
+++ trunk/messaging/build.xml 2007-09-20 22:42:14 UTC (rev 65511)
@@ -30,8 +30,11 @@
| It also sets up the basic extention tasks amoung other things.
-->
- &buildmagic;
+ <property name="javac.target" value="1.5"/>
+ <property name="javac.source" value="1.5"/>
+ &buildmagic;
+
<!--
| Include the normal targets.
-->
@@ -81,6 +84,8 @@
<path refid="jboss.j2se.classpath"/>
<path refid="jboss.messaging.classpath"/>
<path refid="jboss.systemjmx.classpath"/>
+ <path refid="jboss.systemjmx.classpath"/>
+ <path refid="jboss.microcontainer.classpath"/>
</path>
<!-- ===== -->
Modified: trunk/messaging/src/main/org/jboss/mq/server/jmx/Queue.java
===================================================================
--- trunk/messaging/src/main/org/jboss/mq/server/jmx/Queue.java 2007-09-20 21:05:41 UTC (rev 65510)
+++ trunk/messaging/src/main/org/jboss/mq/server/jmx/Queue.java 2007-09-20 22:42:14 UTC (rev 65511)
@@ -22,7 +22,6 @@
package org.jboss.mq.server.jmx;
import java.util.List;
-import java.util.Collections;
import javax.management.MBeanRegistration;
import javax.management.MBeanServer;
@@ -30,249 +29,330 @@
import javax.management.NotificationListener;
import javax.management.ObjectName;
+import org.jboss.jms.server.destination.QueueService;
+import org.jboss.managed.api.ManagedOperation.Impact;
+import org.jboss.managed.api.annotation.ManagementComponent;
+import org.jboss.managed.api.annotation.ManagementObject;
+import org.jboss.managed.api.annotation.ManagementOperation;
+import org.jboss.managed.api.annotation.ManagementProperties;
+import org.jboss.managed.api.annotation.ManagementProperty;
+import org.jboss.managed.api.annotation.ViewUse;
import org.w3c.dom.Element;
-import org.jboss.jms.server.destination.QueueService;
/**
- * Portability class that maps the mbean ops onto the org.jboss.jms.server.destination.QueueService.
+ * Portability class that maps the mbean ops onto the
+ * org.jboss.jms.server.destination.QueueService.
*
* @author Scott.Stark at jboss.org
+ * @author Clebert.suconic at jboss.com
* @version $Revision:$
*/
-public class Queue
- implements MBeanRegistration, QueueMBean
-{
- private QueueService delegate;
+ at ManagementObject(componentType = @ManagementComponent(type = "JMSDestination", subtype = "Queue"), properties = ManagementProperties.EXPLICIT)
+public class Queue implements MBeanRegistration, QueueMBean {
+ private QueueService delegate;
- public Queue()
- {
- delegate = new QueueService();
- }
- public Queue(boolean createProgramatically)
- {
- delegate = new QueueService(createProgramatically);
- }
+ public Queue() {
+ delegate = new QueueService();
+ }
- public void addNotificationListener(NotificationListener listener,
- NotificationFilter filter, Object handback)
- {
- delegate.addNotificationListener(listener, filter, handback);
- }
+ public Queue(boolean createProgramatically) {
+ delegate = new QueueService(createProgramatically);
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#create()
- */
- public void create() throws Exception
- {
- delegate.create();
- }
+ public void addNotificationListener(NotificationListener listener,
+ NotificationFilter filter, Object handback) {
+ delegate.addNotificationListener(listener, filter, handback);
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#destroy()
- */
- public void destroy()
- {
- delegate.destroy();
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#create()
+ */
+ @ManagementOperation(description = "Service lifecycle operation", impact = Impact.WriteOnly)
+ public void create() throws Exception {
+ delegate.create();
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#getDownCacheSize()
- */
- public int getDownCacheSize()
- {
- return delegate.getDownCacheSize();
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#destroy()
+ */
+ @ManagementOperation(description = "Service lifecycle operation", impact = Impact.WriteOnly)
+ public void destroy() {
+ delegate.destroy();
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#getFullSize()
- */
- public int getFullSize()
- {
- return delegate.getFullSize();
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#getDownCacheSize()
+ */
+
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#getJNDIName()
- */
- public String getJNDIName()
- {
- return delegate.getJNDIName();
- }
+ @ManagementProperty(use={ViewUse.CONFIGURATION}, description="The write-cache size, can only be set when queue is stopped")
+ public int getDownCacheSize() {
+ return delegate.getDownCacheSize();
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#getMessageCount()
- */
- public int getMessageCount() throws Exception
- {
- return delegate.getMessageCount();
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#getFullSize()
+ */
+ @ManagementProperty(use={ViewUse.CONFIGURATION}, description="The in-memory message limit, can only be set when queue is stopped")
+ public int getFullSize() {
+ return delegate.getFullSize();
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#getJNDIName()
+ */
+
+ @ManagementProperty(use={ViewUse.RUNTIME})
+ public String getJNDIName() {
+ return delegate.getJNDIName();
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#getName()
- */
- public String getName()
- {
- return delegate.getName();
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#getMessageCount()
+ */
+ @ManagementProperty(use={ViewUse.STATISTIC})
+ public int getMessageCount() throws Exception {
+ return delegate.getMessageCount();
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#getPageSize()
- */
- public int getPageSize()
- {
- return delegate.getPageSize();
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#getName()
+ */
+ @ManagementProperty(use={ViewUse.RUNTIME})
+ public String getName() {
+ return delegate.getName();
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#getServerPeer()
- */
- public ObjectName getServerPeer()
- {
- return delegate.getServerPeer();
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#getPageSize()
+ */
+ @ManagementProperty(use={ViewUse.CONFIGURATION}, description="he paging size, can only be set when queue is stopped")
+ public int getPageSize() {
+ return delegate.getPageSize();
+ }
- public ObjectName getServiceName()
- {
- return delegate.getServiceName();
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#getServerPeer()
+ */
+ @ManagementProperty(use={ViewUse.RUNTIME})
+ public ObjectName getServerPeer() {
+ return delegate.getServerPeer();
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#isCreatedProgrammatically()
- */
- public boolean isCreatedProgrammatically()
- {
- return delegate.isCreatedProgrammatically();
- }
+ public ObjectName getServiceName() {
+ return delegate.getServiceName();
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#listMessages(java.lang.String)
- */
- public List listMessages(String arg0) throws Exception
- {
- //return delegate.listMessages(arg0);
- return Collections.EMPTY_LIST;
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#isCreatedProgrammatically()
+ */
+ @ManagementProperty(use={ViewUse.STATISTIC})
+ public boolean isCreatedProgrammatically() {
+ return delegate.isCreatedProgrammatically();
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#removeAllMessages()
- */
- public void removeAllMessages() throws Exception
- {
- delegate.removeAllMessages();
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#listMessages(java.lang.String)
+ */
+ @ManagementOperation(description = "List all mesages with the selector", impact = Impact.ReadOnly)
+ public List listMessages(String arg0) throws Exception {
+ return delegate.listAllMessages(arg0);
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#setDownCacheSize(int)
- */
- public void setDownCacheSize(int arg0)
- {
- delegate.setDownCacheSize(arg0);
- }
+ @ManagementOperation(description = "List all mesages", impact = Impact.ReadOnly)
+ public List listAllMessages() throws Exception {
+ return delegate.listAllMessages();
+ }
+
+ @ManagementOperation(description = "List all durable mesages", impact = Impact.ReadOnly)
+ public List listDurableMessages() throws Exception
+ {
+ return delegate.listDurableMessages();
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#setFullSize(int)
- */
- public void setFullSize(int arg0)
- {
- delegate.setFullSize(arg0);
- }
+ @ManagementOperation(description = "List all durable mesages using a selector", impact = Impact.ReadOnly)
+ public List listDurableMessages(String selector) throws Exception
+ {
+ return delegate.listDurableMessages(selector);
+ }
+
+ @ManagementOperation(description = "List all non durable mesages", impact = Impact.ReadOnly)
+ public List listNonDurableMessages() throws Exception
+ {
+ return delegate.listNonDurableMessages();
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#setJNDIName(java.lang.String)
- */
- public void setJNDIName(String arg0) throws Exception
- {
- delegate.setJNDIName(arg0);
- }
+ @ManagementOperation(description = "List all non durable mesages using a selector", impact = Impact.ReadOnly)
+ public List listNonDurableMessages(String selector) throws Exception
+ {
+ return delegate.listNonDurableMessages(selector);
+ }
+
+ @ManagementOperation(description = "Reset the message counter", impact = Impact.WriteOnly)
+ public void resetMessageCounter() throws Exception
+ {
+ delegate.resetMessageCounter();
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#setPageSize(int)
- */
- public void setPageSize(int arg0)
- {
- delegate.setPageSize(arg0);
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#removeAllMessages()
+ */
+ @ManagementOperation(description = "Remove all messages in the queue", impact = Impact.WriteOnly)
+ public void removeAllMessages() throws Exception {
+ delegate.removeAllMessages();
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#setSecurityConfig(org.w3c.dom.Element)
- */
- public void setSecurityConfig(Element arg0) throws Exception
- {
- delegate.setSecurityConfig(arg0);
- }
- public void setSecurityConf(Element arg0) throws Exception
- {
- delegate.setSecurityConfig(arg0);
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#setDownCacheSize(int)
+ */
+ public void setDownCacheSize(int arg0) {
+ delegate.setDownCacheSize(arg0);
+ }
- public void setSecurityManager(ObjectName arg0)
- {
- // noop
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#setFullSize(int)
+ */
+ public void setFullSize(int arg0) {
+ delegate.setFullSize(arg0);
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#setServerPeer(javax.management.ObjectName)
- */
- public void setServerPeer(ObjectName arg0)
- {
- delegate.setServerPeer(arg0);
- }
- public void setDestinationManager(ObjectName arg0) throws Exception
- {
- ObjectName peer = new ObjectName("jboss.messaging:service=ServerPeer");
- delegate.setServerPeer(peer);
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#setJNDIName(java.lang.String)
+ */
+ public void setJNDIName(String arg0) throws Exception {
+ delegate.setJNDIName(arg0);
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#start()
- */
- public void start() throws Exception
- {
- delegate.start();
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#setPageSize(int)
+ */
+ public void setPageSize(int arg0) {
+ delegate.setPageSize(arg0);
+ }
- /* (non-Javadoc)
- * @see org.jboss.mq.server.jmx.QueueMBean#stop()
- */
- public void stop()
- {
- delegate.stop();
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#setSecurityConfig(org.w3c.dom.Element)
+ */
+ public void setSecurityConfig(Element arg0) throws Exception {
+ delegate.setSecurityConfig(arg0);
+ }
- public void setMessageCounterHistoryDayLimit(int arg0)
- {
- // noop
- }
+ public void setSecurityConf(Element arg0) throws Exception {
+ delegate.setSecurityConfig(arg0);
+ }
- public ObjectName getExpiryDestination()
- {
- return null;
- }
- public void setExpiryDestination(ObjectName destination)
- {
- System.err.println("There is no ExpiryDestination currently");
- }
+ public void setSecurityManager(ObjectName arg0) {
+ // noop
+ }
- public String toString()
- {
- return delegate.toString();
- }
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#setServerPeer(javax.management.ObjectName)
+ */
+ public void setServerPeer(ObjectName arg0) {
+ delegate.setServerPeer(arg0);
+ }
- public void postDeregister()
- {
- delegate.postDeregister();
- }
- public void postRegister(Boolean registrationDone)
- {
- delegate.postRegister(registrationDone);
- }
- public void preDeregister() throws Exception
- {
- delegate.preDeregister();
- }
- public ObjectName preRegister(MBeanServer server, ObjectName name)
- throws Exception
- {
- return delegate.preRegister(server, name);
- }
+ public void setDestinationManager(ObjectName arg0) throws Exception {
+ ObjectName peer = new ObjectName("jboss.messaging:service=ServerPeer");
+ delegate.setServerPeer(peer);
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#start()
+ */
+ @ManagementOperation(description = "Service lifecycle operation", impact = Impact.WriteOnly)
+ public void start() throws Exception {
+ delegate.start();
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.jboss.mq.server.jmx.QueueMBean#stop()
+ */
+ @ManagementOperation(description = "Service lifecycle operation", impact = Impact.WriteOnly)
+ public void stop() {
+ delegate.stop();
+ }
+
+ public void setMessageCounterHistoryDayLimit(int arg0) {
+ // noop
+ }
+
+ @ManagementProperty(use={ViewUse.CONFIGURATION})
+ public ObjectName getExpiryDestination()
+ {
+ return delegate.getExpiryQueue();
+ }
+
+ public void setExpiryDestination(ObjectName destination)
+ {
+ try
+ {
+ delegate.setExpiryQueue(destination);
+ }
+ catch (Exception e)
+ {
+ throw new RuntimeException(e);
+ }
+ }
+
+ public String toString() {
+ return delegate.toString();
+ }
+
+ public void postDeregister() {
+ delegate.postDeregister();
+ }
+
+ public void postRegister(Boolean registrationDone) {
+ delegate.postRegister(registrationDone);
+ }
+
+ public void preDeregister() throws Exception {
+ delegate.preDeregister();
+ }
+
+ public ObjectName preRegister(MBeanServer server, ObjectName name)
+ throws Exception {
+ return delegate.preRegister(server, name);
+ }
}
Modified: trunk/messaging/src/main/org/jboss/mq/server/jmx/Topic.java
===================================================================
--- trunk/messaging/src/main/org/jboss/mq/server/jmx/Topic.java 2007-09-20 21:05:41 UTC (rev 65510)
+++ trunk/messaging/src/main/org/jboss/mq/server/jmx/Topic.java 2007-09-20 22:42:14 UTC (rev 65511)
@@ -29,6 +29,13 @@
import org.w3c.dom.Element;
import org.jboss.jms.server.destination.TopicService;
+import org.jboss.managed.api.ManagedOperation.Impact;
+import org.jboss.managed.api.annotation.ManagementComponent;
+import org.jboss.managed.api.annotation.ManagementObject;
+import org.jboss.managed.api.annotation.ManagementOperation;
+import org.jboss.managed.api.annotation.ManagementProperties;
+import org.jboss.managed.api.annotation.ManagementProperty;
+import org.jboss.managed.api.annotation.ViewUse;
/**
* Portability class that maps the mbean ops onto the org.jboss.jms.server.destination.TopicService.
@@ -36,6 +43,7 @@
* @author Scott.Stark at jboss.org
* @version $Revision:$
*/
+ at ManagementObject(componentType = @ManagementComponent(type = "JMSDestination", subtype = "Topic"), properties = ManagementProperties.EXPLICIT)
public class Topic
implements MBeanRegistration, TopicMBean
{
@@ -53,6 +61,7 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#create()
*/
+ @ManagementOperation(description = "Service lifecycle operation", impact = Impact.WriteOnly)
public void create() throws Exception
{
delegate.create();
@@ -61,6 +70,7 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#destroy()
*/
+ @ManagementOperation(description = "Service lifecycle operation", impact = Impact.WriteOnly)
public void destroy()
{
delegate.destroy();
@@ -69,6 +79,7 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#getDownCacheSize()
*/
+ @ManagementProperty(use={ViewUse.CONFIGURATION}, description="The write-cache size, can only be set when queue is stopped")
public int getDownCacheSize()
{
return delegate.getDownCacheSize();
@@ -77,6 +88,7 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#getFullSize()
*/
+ @ManagementProperty(use={ViewUse.CONFIGURATION}, description="The in-memory message limit, can only be set when queue is stopped")
public int getFullSize()
{
return delegate.getFullSize();
@@ -85,11 +97,13 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#getJNDIName()
*/
+ @ManagementProperty(use={ViewUse.RUNTIME})
public String getJNDIName()
{
return delegate.getJNDIName();
}
+ @ManagementOperation(description = "List all non durable mesages", impact = Impact.ReadOnly)
public List listNonDurableMessages(String subscriptionId) throws Exception
{
return delegate.listNonDurableMessages(subscriptionId);
@@ -98,6 +112,7 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#getName()
*/
+ @ManagementProperty(use={ViewUse.RUNTIME})
public String getName()
{
return delegate.getName();
@@ -106,6 +121,7 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#getPageSize()
*/
+ @ManagementProperty(use={ViewUse.CONFIGURATION}, description="he paging size, can only be set when queue is stopped")
public int getPageSize()
{
return delegate.getPageSize();
@@ -130,6 +146,7 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#isCreatedProgrammatically()
*/
+ @ManagementProperty(use={ViewUse.STATISTIC})
public boolean isCreatedProgrammatically()
{
return delegate.isCreatedProgrammatically();
@@ -138,6 +155,7 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#listMessagesDurableSub(java.lang.String, java.lang.String, java.lang.String)
*/
+ @ManagementOperation(description = "List all durable mesages", impact = Impact.ReadOnly)
public List listMessagesDurableSub(String arg0, String arg1, String arg2) throws Exception
{
return delegate.listDurableMessages(arg0, arg1);
@@ -146,6 +164,7 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#listMessagesNonDurableSub(long, java.lang.String)
*/
+ @ManagementOperation(description = "List all non durable mesages", impact = Impact.ReadOnly)
public List listMessagesNonDurableSub(long arg0, String arg1) throws Exception
{
return delegate.listNonDurableMessages(arg1);
@@ -154,6 +173,7 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#listSubscriptionsAsText()
*/
+ @ManagementOperation(description = "List subscriptions on text", impact = Impact.ReadOnly)
public String listSubscriptionsAsText() throws Exception
{
return delegate.listAllSubscriptionsAsHTML();
@@ -162,6 +182,7 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#listSubscriptionsAsText(boolean)
*/
+ @ManagementOperation(description = "List subscriptions on text", impact = Impact.ReadOnly)
public String listSubscriptionsAsText(boolean arg0) throws Exception
{
return delegate.listAllSubscriptionsAsHTML();
@@ -170,6 +191,7 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#removeAllMessages()
*/
+ @ManagementOperation(description = "Remove all the messages on the queue DB", impact = Impact.WriteOnly)
public void removeAllMessages() throws Exception
{
delegate.removeAllMessages();
@@ -249,6 +271,7 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#start()
*/
+ @ManagementOperation(description = "Service lifecycle operation", impact = Impact.WriteOnly)
public void start() throws Exception
{
delegate.start();
@@ -257,6 +280,7 @@
/* (non-Javadoc)
* @see org.jboss.mq.server.jmx.TopicMBean#stop()
*/
+ @ManagementOperation(description = "Service lifecycle operation", impact = Impact.WriteOnly)
public void stop()
{
delegate.stop();
More information about the jboss-cvs-commits
mailing list