[jboss-cvs] JBoss Messaging SVN: r7583 - in trunk/src/main/org/jboss/messaging: jms/server/management and 1 other directory.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Fri Jul 17 04:08:55 EDT 2009
Author: jmesnil
Date: 2009-07-17 04:08:55 -0400 (Fri, 17 Jul 2009)
New Revision: 7583
Added:
trunk/src/main/org/jboss/messaging/core/management/MessagingComponentControl.java
Removed:
trunk/src/main/org/jboss/messaging/core/management/MessagingComponentControlMBean.java
Modified:
trunk/src/main/org/jboss/messaging/core/management/AcceptorControl.java
trunk/src/main/org/jboss/messaging/core/management/BridgeControl.java
trunk/src/main/org/jboss/messaging/core/management/BroadcastGroupControl.java
trunk/src/main/org/jboss/messaging/core/management/ClusterConnectionControl.java
trunk/src/main/org/jboss/messaging/core/management/DiscoveryGroupControl.java
trunk/src/main/org/jboss/messaging/core/management/MessagingServerControl.java
trunk/src/main/org/jboss/messaging/core/management/QueueControl.java
trunk/src/main/org/jboss/messaging/jms/server/management/JMSQueueControl.java
trunk/src/main/org/jboss/messaging/jms/server/management/JMSServerControl.java
trunk/src/main/org/jboss/messaging/jms/server/management/TopicControl.java
Log:
* renamed MessagingComponentControlMBean to MessagingComponentControl
* formatted code
Modified: trunk/src/main/org/jboss/messaging/core/management/AcceptorControl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/AcceptorControl.java 2009-07-16 14:06:35 UTC (rev 7582)
+++ trunk/src/main/org/jboss/messaging/core/management/AcceptorControl.java 2009-07-17 08:08:55 UTC (rev 7583)
@@ -30,7 +30,7 @@
* @author <a href="jmesnil at redhat.com">Jeff Mesnil</a>
*
*/
-public interface AcceptorControl extends MessagingComponentControlMBean
+public interface AcceptorControl extends MessagingComponentControl
{
void pause() throws Exception;
Modified: trunk/src/main/org/jboss/messaging/core/management/BridgeControl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/BridgeControl.java 2009-07-16 14:06:35 UTC (rev 7582)
+++ trunk/src/main/org/jboss/messaging/core/management/BridgeControl.java 2009-07-17 08:08:55 UTC (rev 7583)
@@ -29,7 +29,7 @@
* @author <a href="jmesnil at redhat.com">Jeff Mesnil</a>
*
*/
-public interface BridgeControl extends MessagingComponentControlMBean
+public interface BridgeControl extends MessagingComponentControl
{
String getName();
Modified: trunk/src/main/org/jboss/messaging/core/management/BroadcastGroupControl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/BroadcastGroupControl.java 2009-07-16 14:06:35 UTC (rev 7582)
+++ trunk/src/main/org/jboss/messaging/core/management/BroadcastGroupControl.java 2009-07-17 08:08:55 UTC (rev 7583)
@@ -29,7 +29,7 @@
* @author <a href="jmesnil at redhat.com">Jeff Mesnil</a>
*
*/
-public interface BroadcastGroupControl extends MessagingComponentControlMBean
+public interface BroadcastGroupControl extends MessagingComponentControl
{
String getName();
Modified: trunk/src/main/org/jboss/messaging/core/management/ClusterConnectionControl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/ClusterConnectionControl.java 2009-07-16 14:06:35 UTC (rev 7582)
+++ trunk/src/main/org/jboss/messaging/core/management/ClusterConnectionControl.java 2009-07-17 08:08:55 UTC (rev 7583)
@@ -30,7 +30,7 @@
* @author <a href="jmesnil at redhat.com">Jeff Mesnil</a>
*
*/
-public interface ClusterConnectionControl extends MessagingComponentControlMBean
+public interface ClusterConnectionControl extends MessagingComponentControl
{
String getName();
Modified: trunk/src/main/org/jboss/messaging/core/management/DiscoveryGroupControl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/DiscoveryGroupControl.java 2009-07-16 14:06:35 UTC (rev 7582)
+++ trunk/src/main/org/jboss/messaging/core/management/DiscoveryGroupControl.java 2009-07-17 08:08:55 UTC (rev 7583)
@@ -28,7 +28,7 @@
* @author <a href="jmesnil at redhat.com">Jeff Mesnil</a>
*
*/
-public interface DiscoveryGroupControl extends MessagingComponentControlMBean
+public interface DiscoveryGroupControl extends MessagingComponentControl
{
String getName();
Copied: trunk/src/main/org/jboss/messaging/core/management/MessagingComponentControl.java (from rev 7582, trunk/src/main/org/jboss/messaging/core/management/MessagingComponentControlMBean.java)
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/MessagingComponentControl.java (rev 0)
+++ trunk/src/main/org/jboss/messaging/core/management/MessagingComponentControl.java 2009-07-17 08:08:55 UTC (rev 7583)
@@ -0,0 +1,38 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+
+package org.jboss.messaging.core.management;
+
+/**
+ * A MessagingComponentControl
+ *
+ * @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
+ */
+public interface MessagingComponentControl
+{
+ boolean isStarted();
+
+ void start() throws Exception;
+
+ void stop() throws Exception;
+}
Deleted: trunk/src/main/org/jboss/messaging/core/management/MessagingComponentControlMBean.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/MessagingComponentControlMBean.java 2009-07-16 14:06:35 UTC (rev 7582)
+++ trunk/src/main/org/jboss/messaging/core/management/MessagingComponentControlMBean.java 2009-07-17 08:08:55 UTC (rev 7583)
@@ -1,38 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source
- * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors
- * by the @authors tag. See the copyright.txt in the distribution for a
- * full listing of individual contributors.
- *
- * This is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation; either version 2.1 of
- * the License, or (at your option) any later version.
- *
- * This software is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this software; if not, write to the Free
- * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
- * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
- */
-
-
-package org.jboss.messaging.core.management;
-
-/**
- * A MessagingComponentControlMBean
- *
- * @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
- */
-public interface MessagingComponentControlMBean
-{
- boolean isStarted();
-
- void start() throws Exception;
-
- void stop() throws Exception;
-}
Modified: trunk/src/main/org/jboss/messaging/core/management/MessagingServerControl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/MessagingServerControl.java 2009-07-16 14:06:35 UTC (rev 7582)
+++ trunk/src/main/org/jboss/messaging/core/management/MessagingServerControl.java 2009-07-17 08:08:55 UTC (rev 7583)
@@ -47,7 +47,7 @@
boolean isClustered();
int getScheduledThreadPoolMaxSize();
-
+
int getThreadPoolMaxSize();
long getSecurityInvalidationInterval();
@@ -89,9 +89,9 @@
public boolean isBackup();
int getAIOBufferSize();
-
+
int getAIOBufferTimeout();
-
+
public long getPagingMaxGlobalSizeBytes();
public String getPagingDirectory();
@@ -125,7 +125,7 @@
long getMessageExpiryScanPeriod();
long getMessageExpiryThreadPriority();
-
+
Object[] getConnectors() throws Exception;
String getConnectorsAsJSON() throws Exception;
@@ -133,32 +133,28 @@
// Operations ----------------------------------------------------
@Operation(desc = "Create a queue with the specified address", impact = ACTION)
- void createQueue(@Parameter(name = "address", desc = "Address of the queue")
- String address, @Parameter(name = "name", desc = "Name of the queue")
- String name) throws Exception;
+ void createQueue(@Parameter(name = "address", desc = "Address of the queue") String address,
+ @Parameter(name = "name", desc = "Name of the queue") String name) throws Exception;
@Operation(desc = "Create a queue", impact = ACTION)
- void createQueue(@Parameter(name = "address", desc = "Address of the queue")
- String address, @Parameter(name = "name", desc = "Name of the queue")
- String name, @Parameter(name = "filter", desc = "Filter of the queue")
- String filter, @Parameter(name = "durable", desc = "Is the queue durable?")
- boolean durable) throws Exception;
+ void createQueue(@Parameter(name = "address", desc = "Address of the queue") String address,
+ @Parameter(name = "name", desc = "Name of the queue") String name,
+ @Parameter(name = "filter", desc = "Filter of the queue") String filter,
+ @Parameter(name = "durable", desc = "Is the queue durable?") boolean durable) throws Exception;
@Operation(desc = "Deploy a queue", impact = ACTION)
- void deployQueue(@Parameter(name = "address", desc = "Address of the queue")
- String address, @Parameter(name = "name", desc = "Name of the queue")
- String name, String filterString) throws Exception;
+ void deployQueue(@Parameter(name = "address", desc = "Address of the queue") String address,
+ @Parameter(name = "name", desc = "Name of the queue") String name,
+ String filterString) throws Exception;
@Operation(desc = "Deploy a queue", impact = ACTION)
- void deployQueue(@Parameter(name = "address", desc = "Address of the queue")
- String address, @Parameter(name = "name", desc = "Name of the queue")
- String name, @Parameter(name = "filter", desc = "Filter of the queue")
- String filter, @Parameter(name = "durable", desc = "Is the queue durable?")
- boolean durable) throws Exception;
+ void deployQueue(@Parameter(name = "address", desc = "Address of the queue") String address,
+ @Parameter(name = "name", desc = "Name of the queue") String name,
+ @Parameter(name = "filter", desc = "Filter of the queue") String filter,
+ @Parameter(name = "durable", desc = "Is the queue durable?") boolean durable) throws Exception;
@Operation(desc = "Destroy a queue", impact = ACTION)
- void destroyQueue(@Parameter(name = "name", desc = "Name of the queue to destroy")
- String name) throws Exception;
+ void destroyQueue(@Parameter(name = "name", desc = "Name of the queue to destroy") String name) throws Exception;
void enableMessageCounters() throws Exception;
@@ -172,32 +168,26 @@
public String[] listPreparedTransactions() throws Exception;
@Operation(desc = "Commit a prepared transaction")
- boolean commitPreparedTransaction(@Parameter(desc = "the Base64 representation of a transaction", name = "transactionAsBase64")
- String transactionAsBase64) throws Exception;
+ boolean commitPreparedTransaction(@Parameter(desc = "the Base64 representation of a transaction", name = "transactionAsBase64") String transactionAsBase64) throws Exception;
@Operation(desc = "Rollback a prepared transaction")
- boolean rollbackPreparedTransaction(@Parameter(desc = "the Base64 representation of a transaction", name = "transactionAsBase64")
- String transactionAsBase64) throws Exception;
+ boolean rollbackPreparedTransaction(@Parameter(desc = "the Base64 representation of a transaction", name = "transactionAsBase64") String transactionAsBase64) throws Exception;
@Operation(desc = "List the client addresses", impact = INFO)
String[] listRemoteAddresses() throws Exception;
@Operation(desc = "List the client addresses which match the given IP Address", impact = INFO)
- String[] listRemoteAddresses(@Parameter(desc = "an IP address", name = "ipAddress")
- String ipAddress) throws Exception;
+ String[] listRemoteAddresses(@Parameter(desc = "an IP address", name = "ipAddress") String ipAddress) throws Exception;
@Operation(desc = "Closes all the connections for the given IP Address", impact = INFO)
- boolean closeConnectionsForAddress(@Parameter(desc = "an IP address", name = "ipAddress")
- String ipAddress) throws Exception;
+ boolean closeConnectionsForAddress(@Parameter(desc = "an IP address", name = "ipAddress") String ipAddress) throws Exception;
@Operation(desc = "List all the connection IDs", impact = INFO)
String[] listConnectionIDs() throws Exception;
@Operation(desc = "List the sessions for the given connectionID", impact = INFO)
- String[] listSessions(@Parameter(desc = "a connection ID", name = "connectionID")
- String connectionID) throws Exception;
+ String[] listSessions(@Parameter(desc = "a connection ID", name = "connectionID") String connectionID) throws Exception;
void sendQueueInfoToQueue(String queueName, String address) throws Exception;
-
}
Modified: trunk/src/main/org/jboss/messaging/core/management/QueueControl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/QueueControl.java 2009-07-16 14:06:35 UTC (rev 7582)
+++ trunk/src/main/org/jboss/messaging/core/management/QueueControl.java 2009-07-17 08:08:55 UTC (rev 7583)
@@ -61,13 +61,11 @@
String getExpiryAddress();
- void setExpiryAddress(@Parameter(name = "expiryAddress", desc = "Expiry address of the queue")
- String expiryAddres) throws Exception;
+ void setExpiryAddress(@Parameter(name = "expiryAddress", desc = "Expiry address of the queue") String expiryAddres) throws Exception;
String getDeadLetterAddress();
- void setDeadLetterAddress(@Parameter(name = "deadLetterAddress", desc = "Dead-letter address of the queue")
- String deadLetterAddress) throws Exception;
+ void setDeadLetterAddress(@Parameter(name = "deadLetterAddress", desc = "Dead-letter address of the queue") String deadLetterAddress) throws Exception;
boolean isBackup();
@@ -80,53 +78,42 @@
String listScheduledMessagesAsJSON() throws Exception;
@Operation(desc = "List all the messages in the queue matching the given filter", impact = INFO)
- Map<String, Object>[] listMessages(@Parameter(name = "filter", desc = "A message filter (can be empty)")
- String filter) throws Exception;
+ Map<String, Object>[] listMessages(@Parameter(name = "filter", desc = "A message filter (can be empty)") String filter) throws Exception;
@Operation(desc = "List all the messages in the queue matching the given filter and returns them using JSON", impact = INFO)
- String listMessagesAsJSON(@Parameter(name = "filter", desc = "A message filter (can be empty)")
- String filter) throws Exception;
+ String listMessagesAsJSON(@Parameter(name = "filter", desc = "A message filter (can be empty)") String filter) throws Exception;
@Operation(desc = "Returns the number of the messages in the queue matching the given filter", impact = INFO)
- int countMessages(@Parameter(name = "filter", desc = "A message filter (can be empty)")
- String filter) throws Exception;
+ int countMessages(@Parameter(name = "filter", desc = "A message filter (can be empty)") String filter) throws Exception;
@Operation(desc = "Remove the message corresponding to the given messageID", impact = ACTION)
- boolean removeMessage(@Parameter(name = "messageID", desc = "A message ID")
- long messageID) throws Exception;
+ boolean removeMessage(@Parameter(name = "messageID", desc = "A message ID") long messageID) throws Exception;
@Operation(desc = "Remove the messages corresponding to the given filter (and returns the number of removed messages)", impact = ACTION)
- int removeMessages(@Parameter(name = "filter", desc = "A message filter (can be empty)")
- String filter) throws Exception;
+ int removeMessages(@Parameter(name = "filter", desc = "A message filter (can be empty)") String filter) throws Exception;
@Operation(desc = "Remove the messages corresponding to the given filter (and returns the number of expired messages)", impact = ACTION)
- int expireMessages(@Parameter(name = "filter", desc = "A message filter")
- String filter) throws Exception;
+ int expireMessages(@Parameter(name = "filter", desc = "A message filter") String filter) throws Exception;
@Operation(desc = "Remove the message corresponding to the given messageID", impact = ACTION)
- boolean expireMessage(@Parameter(name = "messageID", desc = "A message ID")
- long messageID) throws Exception;
+ boolean expireMessage(@Parameter(name = "messageID", desc = "A message ID") long messageID) throws Exception;
@Operation(desc = "Move the message corresponding to the given messageID to another queue", impact = ACTION)
- boolean moveMessage(@Parameter(name = "messageID", desc = "A message ID")
- long messageID, @Parameter(name = "otherQueueName", desc = "The name of the queue to move the message to")
- String otherQueueName) throws Exception;
+ boolean moveMessage(@Parameter(name = "messageID", desc = "A message ID") long messageID,
+ @Parameter(name = "otherQueueName", desc = "The name of the queue to move the message to") String otherQueueName) throws Exception;
@Operation(desc = "Move the messages corresponding to the given filter (and returns the number of moved messages)", impact = ACTION)
- int moveMessages(@Parameter(name = "filter", desc = "A message filter (can be empty)")
- String filter, @Parameter(name = "otherQueueName", desc = "The name of the queue to move the messages to")
- String otherQueueName) throws Exception;
+ int moveMessages(@Parameter(name = "filter", desc = "A message filter (can be empty)") String filter,
+ @Parameter(name = "otherQueueName", desc = "The name of the queue to move the messages to") String otherQueueName) throws Exception;
@Operation(desc = "Send the message corresponding to the given messageID to this queue's Dead Letter Address", impact = ACTION)
- boolean sendMessageToDeadLetterAddress(@Parameter(name = "messageID", desc = "A message ID")
- long messageID) throws Exception;
+ boolean sendMessageToDeadLetterAddress(@Parameter(name = "messageID", desc = "A message ID") long messageID) throws Exception;
int sendMessagesToDeadLetterAddress(String filterStr) throws Exception;
@Operation(desc = "Change the priority of the message corresponding to the given messageID", impact = ACTION)
- boolean changeMessagePriority(@Parameter(name = "messageID", desc = "A message ID")
- long messageID, @Parameter(name = "newPriority", desc = "the new priority (between 0 and 9)")
- int newPriority) throws Exception;
+ boolean changeMessagePriority(@Parameter(name = "messageID", desc = "A message ID") long messageID,
+ @Parameter(name = "newPriority", desc = "the new priority (between 0 and 9)") int newPriority) throws Exception;
int changeMessagesPriority(String filter, int newPriority) throws Exception;
Modified: trunk/src/main/org/jboss/messaging/jms/server/management/JMSQueueControl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/server/management/JMSQueueControl.java 2009-07-16 14:06:35 UTC (rev 7582)
+++ trunk/src/main/org/jboss/messaging/jms/server/management/JMSQueueControl.java 2009-07-17 08:08:55 UTC (rev 7583)
@@ -44,13 +44,11 @@
String getExpiryAddress();
- void setExpiryAddress(@Parameter(name = "expiryAddress", desc = "Expiry address of the queue")
- String expiryAddress) throws Exception;
+ void setExpiryAddress(@Parameter(name = "expiryAddress", desc = "Expiry address of the queue") String expiryAddress) throws Exception;
String getDeadLetterAddress();
- void setDeadLetterAddress(@Parameter(name = "deadLetterAddress", desc = "Dead-letter address of the queue")
- String deadLetterAddress) throws Exception;
+ void setDeadLetterAddress(@Parameter(name = "deadLetterAddress", desc = "Dead-letter address of the queue") String deadLetterAddress) throws Exception;
int getMessagesAdded();
@@ -69,51 +67,40 @@
// Operations ----------------------------------------------------
@Operation(desc = "List all messages in the queue which matches the filter", impact = INFO)
- Map<String, Object>[] listMessages(@Parameter(name = "filter", desc = "A JMS Message filter")
- String filter) throws Exception;
+ Map<String, Object>[] listMessages(@Parameter(name = "filter", desc = "A JMS Message filter") String filter) throws Exception;
@Operation(desc = "List all messages in the queue which matches the filter and return them using JSON", impact = INFO)
- String listMessagesAsJSON(@Parameter(name = "filter", desc = "A JMS Message filter (can be empty)")
- String filter) throws Exception;
+ String listMessagesAsJSON(@Parameter(name = "filter", desc = "A JMS Message filter (can be empty)") String filter) throws Exception;
@Operation(desc = "Returns the number of the messages in the queue matching the given filter", impact = INFO)
- int countMessages(@Parameter(name = "filter", desc = "A JMS message filter (can be empty)")
- String filter) throws Exception;
+ int countMessages(@Parameter(name = "filter", desc = "A JMS message filter (can be empty)") String filter) throws Exception;
@Operation(desc = "Remove the message corresponding to the given messageID", impact = ACTION)
- boolean removeMessage(@Parameter(name = "messageID", desc = "A message ID")
- String messageID) throws Exception;
+ boolean removeMessage(@Parameter(name = "messageID", desc = "A message ID") String messageID) throws Exception;
@Operation(desc = "Remove the messages corresponding to the given filter (and returns the number of removed messages)", impact = ACTION)
- int removeMessages(@Parameter(name = "filter", desc = "A message filter (can be empty)")
- String filter) throws Exception;
+ int removeMessages(@Parameter(name = "filter", desc = "A message filter (can be empty)") String filter) throws Exception;
@Operation(desc = "Expire the messages corresponding to the given filter (and returns the number of expired messages)", impact = ACTION)
- int expireMessages(@Parameter(name = "filter", desc = "A message filter (can be empty)")
- String filter) throws Exception;
+ int expireMessages(@Parameter(name = "filter", desc = "A message filter (can be empty)") String filter) throws Exception;
@Operation(desc = "Expire the message corresponding to the given messageID", impact = ACTION)
- boolean expireMessage(@Parameter(name = "messageID", desc = "A message ID")
- String messageID) throws Exception;
+ boolean expireMessage(@Parameter(name = "messageID", desc = "A message ID") String messageID) throws Exception;
@Operation(desc = "Send the message corresponding to the given messageID to the queue's Dead Letter Queue", impact = ACTION)
- boolean sendMessageToDeadLetterAddress(@Parameter(name = "messageID", desc = "A message ID")
- String messageID) throws Exception;
+ boolean sendMessageToDeadLetterAddress(@Parameter(name = "messageID", desc = "A message ID") String messageID) throws Exception;
@Operation(desc = "Change the priority of the message corresponding to the given messageID", impact = ACTION)
- boolean changeMessagePriority(@Parameter(name = "messageID", desc = "A message ID")
- String messageID, @Parameter(name = "newPriority", desc = "the new priority (between 0 and 9)")
- int newPriority) throws Exception;
+ boolean changeMessagePriority(@Parameter(name = "messageID", desc = "A message ID") String messageID,
+ @Parameter(name = "newPriority", desc = "the new priority (between 0 and 9)") int newPriority) throws Exception;
@Operation(desc = "Move the message corresponding to the given messageID to another queue", impact = ACTION)
- boolean moveMessage(@Parameter(name = "messageID", desc = "A message ID")
- String messageID, @Parameter(name = "otherQueueName", desc = "The name of the queue to move the message to")
- String otherQueueName) throws Exception;
+ boolean moveMessage(@Parameter(name = "messageID", desc = "A message ID") String messageID,
+ @Parameter(name = "otherQueueName", desc = "The name of the queue to move the message to") String otherQueueName) throws Exception;
@Operation(desc = "Move the messages corresponding to the given filter (and returns the number of moved messages)", impact = ACTION)
- int moveMessages(@Parameter(name = "filter", desc = "A message filter (can be empty)")
- String filter, @Parameter(name = "otherQueueName", desc = "The name of the queue to move the messages to")
- String otherQueueName) throws Exception;
+ int moveMessages(@Parameter(name = "filter", desc = "A message filter (can be empty)") String filter,
+ @Parameter(name = "otherQueueName", desc = "The name of the queue to move the messages to") String otherQueueName) throws Exception;
String listMessageCounter() throws Exception;
Modified: trunk/src/main/org/jboss/messaging/jms/server/management/JMSServerControl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/server/management/JMSServerControl.java 2009-07-16 14:06:35 UTC (rev 7582)
+++ trunk/src/main/org/jboss/messaging/jms/server/management/JMSServerControl.java 2009-07-17 08:08:55 UTC (rev 7583)
@@ -48,22 +48,18 @@
// Operations ----------------------------------------------------
@Operation(desc = "Create a JMS Queue", impact = ACTION)
- boolean createQueue(@Parameter(name = "name", desc = "Name of the queue to create")
- String name, @Parameter(name = "jndiBinding", desc = "the name of the binding for JNDI")
- String jndiBinding) throws Exception;
+ boolean createQueue(@Parameter(name = "name", desc = "Name of the queue to create") String name,
+ @Parameter(name = "jndiBinding", desc = "the name of the binding for JNDI") String jndiBinding) throws Exception;
@Operation(desc = "Destroy a JMS Queue", impact = ACTION)
- boolean destroyQueue(@Parameter(name = "name", desc = "Name of the queue to destroy")
- String name) throws Exception;
+ boolean destroyQueue(@Parameter(name = "name", desc = "Name of the queue to destroy") String name) throws Exception;
@Operation(desc = "Create a JMS Topic", impact = ACTION)
- boolean createTopic(@Parameter(name = "name", desc = "Name of the topic to create")
- String name, @Parameter(name = "jndiBinding", desc = "the name of the binding for JNDI")
- String jndiBinding) throws Exception;
+ boolean createTopic(@Parameter(name = "name", desc = "Name of the topic to create") String name,
+ @Parameter(name = "jndiBinding", desc = "the name of the binding for JNDI") String jndiBinding) throws Exception;
@Operation(desc = "Destroy a JMS Topic", impact = ACTION)
- boolean destroyTopic(@Parameter(name = "name", desc = "Name of the topic to destroy")
- String name) throws Exception;
+ boolean destroyTopic(@Parameter(name = "name", desc = "Name of the topic to destroy") String name) throws Exception;
void createConnectionFactory(String name,
Object[] liveConnectorsTransportClassNames,
@@ -154,7 +150,7 @@
String liveTransportClassName,
Map<String, Object> liveTransportParams,
Object[] jndiBindings) throws Exception;
-
+
void createConnectionFactory(String name,
String liveTransportClassName,
Map<String, Object> liveTransportParams,
@@ -177,24 +173,20 @@
Object[] jndiBindings) throws Exception;
@Operation(desc = "Create a JMS ConnectionFactory", impact = ACTION)
- void destroyConnectionFactory(@Parameter(name = "name", desc = "Name of the ConnectionFactory to create")
- String name) throws Exception;
+ void destroyConnectionFactory(@Parameter(name = "name", desc = "Name of the ConnectionFactory to create") String name) throws Exception;
@Operation(desc = "List the client addresses", impact = INFO)
String[] listRemoteAddresses() throws Exception;
@Operation(desc = "List the client addresses which match the given IP Address", impact = INFO)
- String[] listRemoteAddresses(@Parameter(desc = "an IP address", name = "ipAddress")
- String ipAddress) throws Exception;
+ String[] listRemoteAddresses(@Parameter(desc = "an IP address", name = "ipAddress") String ipAddress) throws Exception;
@Operation(desc = "Closes all the connections for the given IP Address", impact = INFO)
- boolean closeConnectionsForAddress(@Parameter(desc = "an IP address", name = "ipAddress")
- String ipAddress) throws Exception;
+ boolean closeConnectionsForAddress(@Parameter(desc = "an IP address", name = "ipAddress") String ipAddress) throws Exception;
@Operation(desc = "List all the connection IDs", impact = INFO)
String[] listConnectionIDs() throws Exception;
@Operation(desc = "List the sessions for the given connectionID", impact = INFO)
- String[] listSessions(@Parameter(desc = "a connection ID", name = "connectionID")
- String connectionID) throws Exception;
+ String[] listSessions(@Parameter(desc = "a connection ID", name = "connectionID") String connectionID) throws Exception;
}
Modified: trunk/src/main/org/jboss/messaging/jms/server/management/TopicControl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/server/management/TopicControl.java 2009-07-16 14:06:35 UTC (rev 7582)
+++ trunk/src/main/org/jboss/messaging/jms/server/management/TopicControl.java 2009-07-17 08:08:55 UTC (rev 7583)
@@ -70,28 +70,19 @@
String listNonDurableSubscriptionsAsJSON() throws Exception;
@Operation(desc = "List all the message for the given subscription")
- public Map<String, Object>[] listMessagesForSubscription(
- @Parameter(name = "queueName", desc = "the name of the queue representing a subscription") String queueName)
- throws Exception;
+ public Map<String, Object>[] listMessagesForSubscription(@Parameter(name = "queueName", desc = "the name of the queue representing a subscription") String queueName) throws Exception;
@Operation(desc = "List all the message for the given subscription")
- public String listMessagesForSubscriptionAsJSON(
- @Parameter(name = "queueName", desc = "the name of the queue representing a subscription") String queueName)
- throws Exception;
+ public String listMessagesForSubscriptionAsJSON(@Parameter(name = "queueName", desc = "the name of the queue representing a subscription") String queueName) throws Exception;
@Operation(desc = "Count the number of messages matching the filter for the given subscription")
- public int countMessagesForSubscription(
- @Parameter(name = "clientID", desc = "the client ID") String clientID,
- @Parameter(name = "subscriptionName", desc = "the name of the durable subscription") String subscriptionName,
- @Parameter(name = "filter", desc = "a JMS filter (can be empty)") String filter)
- throws Exception;
+ public int countMessagesForSubscription(@Parameter(name = "clientID", desc = "the client ID") String clientID,
+ @Parameter(name = "subscriptionName", desc = "the name of the durable subscription") String subscriptionName,
+ @Parameter(name = "filter", desc = "a JMS filter (can be empty)") String filter) throws Exception;
@Operation(desc = "Drop a durable subscription", impact = ACTION)
- void dropDurableSubscription(
- @Parameter(name = "clientID", desc = "the client ID") String clientID,
- @Parameter(name = "subscriptionName", desc = "the name of the durable subscription") String subscriptionName)
- throws Exception;
-
+ void dropDurableSubscription(@Parameter(name = "clientID", desc = "the client ID") String clientID,
+ @Parameter(name = "subscriptionName", desc = "the name of the durable subscription") String subscriptionName) throws Exception;
@Operation(desc = "Drop all subscriptions from this topic", impact = ACTION)
void dropAllSubscriptions() throws Exception;
More information about the jboss-cvs-commits
mailing list