[jboss-cvs] JBoss Messaging SVN: r6114 - in trunk: src/main/org/jboss/messaging/core/config and 11 other directories.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Thu Mar 19 10:50:18 EDT 2009
Author: jmesnil
Date: 2009-03-19 10:50:18 -0400 (Thu, 19 Mar 2009)
New Revision: 6114
Added:
trunk/tests/src/org/jboss/messaging/tests/integration/management/core/MessagingServerControlUsingCoreTest.java
Modified:
trunk/src/main/org/jboss/messaging/core/client/management/impl/ManagementHelper.java
trunk/src/main/org/jboss/messaging/core/config/TransportConfiguration.java
trunk/src/main/org/jboss/messaging/core/management/MessagingServerControlMBean.java
trunk/src/main/org/jboss/messaging/core/management/impl/ManagementServiceImpl.java
trunk/src/main/org/jboss/messaging/core/management/impl/MessagingServerControl.java
trunk/src/main/org/jboss/messaging/core/management/jmx/impl/ReplicationAwareMessagingServerControlWrapper.java
trunk/src/main/org/jboss/messaging/core/messagecounter/impl/MessageCounterManagerImpl.java
trunk/src/main/org/jboss/messaging/jms/server/JMSServerManager.java
trunk/src/main/org/jboss/messaging/jms/server/impl/JMSServerManagerImpl.java
trunk/src/main/org/jboss/messaging/jms/server/management/impl/JMSServerControl.java
trunk/src/main/org/jboss/messaging/jms/server/management/jmx/impl/ReplicationAwareJMSServerControlWrapper.java
trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/JMSMessagingProxy.java
trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/JMSQueueControlUsingJMSTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/JMSServerControlUsingJMSTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/TopicControlUsingJMSTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/MessagingServerControlTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/core/CoreAddressControlTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/core/CoreMessagingProxy.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/core/CoreQueueControlTest.java
Log:
management integration tests
* added integration tests for MessagingServerControl
* fixed typo in {Core|JMS}MessagingProxy classes
Modified: trunk/src/main/org/jboss/messaging/core/client/management/impl/ManagementHelper.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/management/impl/ManagementHelper.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/src/main/org/jboss/messaging/core/client/management/impl/ManagementHelper.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -78,6 +78,8 @@
public static final SimpleString HDR_DISTANCE = new SimpleString("_JBM_Distance");
+ private static final SimpleString NULL = new SimpleString("_JBM_NULL");
+
// Attributes ----------------------------------------------------
// Static --------------------------------------------------------
@@ -130,7 +132,7 @@
{
value = value.toString();
}
- if ("null".equals(value))
+ if (NULL.toString().equals(value))
{
value = null;
}
@@ -206,6 +208,7 @@
{
if (typedProperty == null)
{
+ message.putStringProperty(key, NULL);
return;
}
Modified: trunk/src/main/org/jboss/messaging/core/config/TransportConfiguration.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/config/TransportConfiguration.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/src/main/org/jboss/messaging/core/config/TransportConfiguration.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -21,7 +21,10 @@
*/
package org.jboss.messaging.core.config;
+import static java.util.Collections.emptyMap;
+
import java.io.Serializable;
+import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;
@@ -193,7 +196,7 @@
public TransportConfiguration(final String className)
{
- this(className, null, UUID.randomUUID().toString());
+ this(className, new HashMap<String, Object>(), UUID.randomUUID().toString());
}
public String getName()
Modified: trunk/src/main/org/jboss/messaging/core/management/MessagingServerControlMBean.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/MessagingServerControlMBean.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/src/main/org/jboss/messaging/core/management/MessagingServerControlMBean.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -127,7 +127,7 @@
void resetAllMessageCounterHistories() throws Exception;
@Operation(desc = "List all the prepared transaction, sorted by date, oldest first")
- public String[] listPreparedTransactions();
+ public String[] listPreparedTransactions() throws Exception;
@Operation(desc = "Commit a prepared transaction")
boolean commitPreparedTransaction(@Parameter(desc = "the Base64 representation of a transaction", name = "transactionAsBase64")
@@ -138,25 +138,60 @@
String transactionAsBase64) throws Exception;
@Operation(desc = "List the client addresses", impact = INFO)
- String[] listRemoteAddresses();
+ 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);
+ 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;
@Operation(desc = "List all the connection IDs", impact = INFO)
- String[] listConnectionIDs();
+ 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);
+ String connectionID) throws Exception;
TabularData getConnectors() throws Exception;
void sendQueueInfoToQueue(String queueName, String address) throws Exception;
+ boolean isAllowRouteWhenNoBindings();
+
+ boolean isPersistDeliveryCountBeforeDelivery();
+
+ long getQueueActivationTimeout();
+
+ long getConnectionTTLOverride();
+
+ String getManagementAddress();
+
+ String getManagementNotificationAddress();
+
+ long getManagementRequestTimeout();
+
+ int getIDCacheSize();
+
+ boolean isPersistIDCache();
+
+ int getPagingMaxThreads();
+
+ int getPagingGlobalWatermarkSize();
+
+ String getLargeMessagesDirectory();
+
+ boolean isWildcardRoutingEnabled();
+
+ long getTransactionTimeout();
+
+ long getTransactionTimeoutScanPeriod();
+
+ long getMessageExpiryScanPeriod();
+
+ long getMessageExpiryThreadPriority();
+
+
}
Modified: trunk/src/main/org/jboss/messaging/core/management/impl/ManagementServiceImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/impl/ManagementServiceImpl.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/src/main/org/jboss/messaging/core/management/impl/ManagementServiceImpl.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -115,7 +115,7 @@
private MessagingServerControl managedServer;
- private final MessageCounterManager messageCounterManager = new MessageCounterManagerImpl(10000);
+ private final MessageCounterManager messageCounterManager = new MessageCounterManagerImpl();
private SimpleString managementNotificationAddress = ConfigurationImpl.DEFAULT_MANAGEMENT_NOTIFICATION_ADDRESS;
Modified: trunk/src/main/org/jboss/messaging/core/management/impl/MessagingServerControl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/impl/MessagingServerControl.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/src/main/org/jboss/messaging/core/management/impl/MessagingServerControl.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -52,6 +52,7 @@
import org.jboss.messaging.core.management.NotificationType;
import org.jboss.messaging.core.management.TransportConfigurationInfo;
import org.jboss.messaging.core.messagecounter.MessageCounterManager;
+import org.jboss.messaging.core.messagecounter.impl.MessageCounterManagerImpl;
import org.jboss.messaging.core.persistence.StorageManager;
import org.jboss.messaging.core.postoffice.Binding;
import org.jboss.messaging.core.postoffice.BindingType;
@@ -140,20 +141,8 @@
// Public --------------------------------------------------------
- public Queue getQueue(final String name) throws Exception
+ public Configuration getConfiguration()
{
- SimpleString sName = new SimpleString(name);
- Binding binding = postOffice.getBinding(sName);
- if (binding == null || binding.getType() != BindingType.LOCAL_QUEUE)
- {
- throw new IllegalArgumentException("No queue with name " + sName);
- }
-
- return (Queue)binding.getBindable();
- }
-
- public Configuration getConfiguration()
- {
return configuration;
}
@@ -369,9 +358,9 @@
public synchronized void setMessageCounterSamplePeriod(final long newPeriod)
{
- if (newPeriod < 1000)
+ if (newPeriod < MessageCounterManagerImpl.MIN_SAMPLE_PERIOD)
{
- throw new IllegalArgumentException("Cannot set MessageCounterSamplePeriod < 1000 ms");
+ throw new IllegalArgumentException("Cannot set MessageCounterSamplePeriod < " + MessageCounterManagerImpl.MIN_SAMPLE_PERIOD + " ms");
}
if (messageCounterManager != null && newPeriod != messageCounterManager.getSamplePeriod())
@@ -524,7 +513,7 @@
Collection<TransportConfiguration> connectorConfigurations = configuration.getConnectorConfigurations().values();
return TransportConfigurationInfo.toTabularData(connectorConfigurations);
}
-
+
public void sendQueueInfoToQueue(final String queueName, final String address) throws Exception
{
postOffice.sendQueueInfoToQueue(new SimpleString(queueName), new SimpleString(address));
@@ -599,4 +588,89 @@
messageCounterManager.resetAllCounterHistories();
}
+
+ public long getConnectionTTLOverride()
+ {
+ return configuration.getConnectionTTLOverride();
+ }
+
+ public int getIDCacheSize()
+ {
+ return configuration.getIDCacheSize();
+ }
+
+ public String getLargeMessagesDirectory()
+ {
+ return configuration.getLargeMessagesDirectory();
+ }
+
+ public String getManagementAddress()
+ {
+ return configuration.getManagementAddress().toString();
+ }
+
+ public String getManagementNotificationAddress()
+ {
+ return configuration.getManagementNotificationAddress().toString();
+ }
+
+ public long getManagementRequestTimeout()
+ {
+ return configuration.getManagementRequestTimeout();
+ }
+
+ public long getMessageExpiryScanPeriod()
+ {
+ return configuration.getMessageExpiryScanPeriod();
+ }
+
+ public long getMessageExpiryThreadPriority()
+ {
+ return configuration.getMessageExpiryThreadPriority();
+ }
+
+ public int getPagingGlobalWatermarkSize()
+ {
+ return configuration.getPagingGlobalWatermarkSize();
+ }
+
+ public int getPagingMaxThreads()
+ {
+ return configuration.getPagingMaxThreads();
+ }
+
+ public long getQueueActivationTimeout()
+ {
+ return configuration.getQueueActivationTimeout();
+ }
+
+ public long getTransactionTimeout()
+ {
+ return configuration.getTransactionTimeout();
+ }
+
+ public long getTransactionTimeoutScanPeriod()
+ {
+ return configuration.getTransactionTimeoutScanPeriod();
+ }
+
+ public boolean isAllowRouteWhenNoBindings()
+ {
+ return configuration.isAllowRouteWhenNoBindings();
+ }
+
+ public boolean isPersistDeliveryCountBeforeDelivery()
+ {
+ return configuration.isPersistDeliveryCountBeforeDelivery();
+ }
+
+ public boolean isPersistIDCache()
+ {
+ return configuration.isPersistIDCache();
+ }
+
+ public boolean isWildcardRoutingEnabled()
+ {
+ return configuration.isWildcardRoutingEnabled();
+ }
}
Modified: trunk/src/main/org/jboss/messaging/core/management/jmx/impl/ReplicationAwareMessagingServerControlWrapper.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/jmx/impl/ReplicationAwareMessagingServerControlWrapper.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/src/main/org/jboss/messaging/core/management/jmx/impl/ReplicationAwareMessagingServerControlWrapper.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -234,7 +234,7 @@
{
return localControl.getConnectors();
}
-
+
public void sendQueueInfoToQueue(final String queueName, final String address) throws Exception
{
localControl.sendQueueInfoToQueue(queueName, address);
@@ -309,7 +309,92 @@
{
replicationAwareInvoke("setMessageCounterSamplePeriod", newPeriod);
}
+
+ public long getConnectionTTLOverride()
+ {
+ return localControl.getConnectionTTLOverride();
+ }
+ public int getIDCacheSize()
+ {
+ return localControl.getIDCacheSize();
+ }
+
+ public String getLargeMessagesDirectory()
+ {
+ return localControl.getLargeMessagesDirectory();
+ }
+
+ public String getManagementAddress()
+ {
+ return localControl.getManagementAddress().toString();
+ }
+
+ public String getManagementNotificationAddress()
+ {
+ return localControl.getManagementNotificationAddress().toString();
+ }
+
+ public long getManagementRequestTimeout()
+ {
+ return localControl.getManagementRequestTimeout();
+ }
+
+ public long getMessageExpiryScanPeriod()
+ {
+ return localControl.getMessageExpiryScanPeriod();
+ }
+
+ public long getMessageExpiryThreadPriority()
+ {
+ return localControl.getMessageExpiryThreadPriority();
+ }
+
+ public int getPagingGlobalWatermarkSize()
+ {
+ return localControl.getPagingGlobalWatermarkSize();
+ }
+
+ public int getPagingMaxThreads()
+ {
+ return localControl.getPagingMaxThreads();
+ }
+
+ public long getQueueActivationTimeout()
+ {
+ return localControl.getQueueActivationTimeout();
+ }
+
+ public long getTransactionTimeout()
+ {
+ return localControl.getTransactionTimeout();
+ }
+
+ public long getTransactionTimeoutScanPeriod()
+ {
+ return localControl.getTransactionTimeoutScanPeriod();
+ }
+
+ public boolean isAllowRouteWhenNoBindings()
+ {
+ return localControl.isAllowRouteWhenNoBindings();
+ }
+
+ public boolean isPersistDeliveryCountBeforeDelivery()
+ {
+ return localControl.isPersistDeliveryCountBeforeDelivery();
+ }
+
+ public boolean isPersistIDCache()
+ {
+ return localControl.isPersistIDCache();
+ }
+
+ public boolean isWildcardRoutingEnabled()
+ {
+ return localControl.isWildcardRoutingEnabled();
+ }
+
// StandardMBean overrides ---------------------------------------
@Override
Modified: trunk/src/main/org/jboss/messaging/core/messagecounter/impl/MessageCounterManagerImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/messagecounter/impl/MessageCounterManagerImpl.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/src/main/org/jboss/messaging/core/messagecounter/impl/MessageCounterManagerImpl.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -45,6 +45,13 @@
*/
public class MessageCounterManagerImpl implements MessageCounterManager
{
+
+ public static final long DEFAULT_SAMPLE_PERIOD = 10000;
+
+ public static final long MIN_SAMPLE_PERIOD = 1000;
+
+ public static final int DEFAULT_MAX_DAY_COUNT = 10;
+
private static final Logger log = Logger.getLogger(MessageCounterManagerImpl.class);
private Map<String, MessageCounter> messageCounters;
@@ -53,17 +60,15 @@
private Timer timer;
- private long period;
+ private long period = DEFAULT_SAMPLE_PERIOD;
private PingMessageCountersTask task;
- private int maxDayCount = 10;
+ private int maxDayCount = DEFAULT_MAX_DAY_COUNT;
- public MessageCounterManagerImpl(long period)
+ public MessageCounterManagerImpl()
{
messageCounters = new HashMap<String, MessageCounter>();
-
- this.period = period;
}
public synchronized void start()
Modified: trunk/src/main/org/jboss/messaging/jms/server/JMSServerManager.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/server/JMSServerManager.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/src/main/org/jboss/messaging/jms/server/JMSServerManager.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -183,15 +183,15 @@
*/
boolean destroyConnectionFactory(String name) throws Exception;
- String[] listRemoteAddresses();
+ String[] listRemoteAddresses() throws Exception;
- String[] listRemoteAddresses(String ipAddress);
+ String[] listRemoteAddresses(String ipAddress) throws Exception;
boolean closeConnectionsForAddress(String ipAddress) throws Exception;
- String[] listConnectionIDs();
+ String[] listConnectionIDs() throws Exception;
- String[] listSessions(String connectionID);
+ String[] listSessions(String connectionID) throws Exception;
}
Modified: trunk/src/main/org/jboss/messaging/jms/server/impl/JMSServerManagerImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/server/impl/JMSServerManagerImpl.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/src/main/org/jboss/messaging/jms/server/impl/JMSServerManagerImpl.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -95,7 +95,7 @@
server.getResourceManager(),
server.getRemotingService(),
server,
- new MessageCounterManagerImpl(1000),
+ new MessageCounterManagerImpl(),
new NotificationBroadcasterSupport(),
server.getQueueFactory());
JMSManagementService jmsManagementService = new JMSManagementServiceImpl(server.getManagementService());
@@ -389,12 +389,12 @@
return true;
}
- public String[] listRemoteAddresses()
+ public String[] listRemoteAddresses() throws Exception
{
return messagingServer.listRemoteAddresses();
}
- public String[] listRemoteAddresses(final String ipAddress)
+ public String[] listRemoteAddresses(final String ipAddress) throws Exception
{
return messagingServer.listRemoteAddresses(ipAddress);
}
@@ -404,12 +404,12 @@
return messagingServer.closeConnectionsForAddress(ipAddress);
}
- public String[] listConnectionIDs()
+ public String[] listConnectionIDs() throws Exception
{
return messagingServer.listConnectionIDs();
}
- public String[] listSessions(final String connectionID)
+ public String[] listSessions(final String connectionID) throws Exception
{
return messagingServer.listSessions(connectionID);
}
Modified: trunk/src/main/org/jboss/messaging/jms/server/management/impl/JMSServerControl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/server/management/impl/JMSServerControl.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/src/main/org/jboss/messaging/jms/server/management/impl/JMSServerControl.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -407,12 +407,12 @@
"Notifications emitted by a JMS Server") };
}
- public String[] listRemoteAddresses()
+ public String[] listRemoteAddresses() throws Exception
{
return server.listRemoteAddresses();
}
- public String[] listRemoteAddresses(final String ipAddress)
+ public String[] listRemoteAddresses(final String ipAddress) throws Exception
{
return server.listRemoteAddresses(ipAddress);
}
@@ -422,12 +422,12 @@
return server.closeConnectionsForAddress(ipAddress);
}
- public String[] listConnectionIDs()
+ public String[] listConnectionIDs() throws Exception
{
return server.listConnectionIDs();
}
- public String[] listSessions(final String connectionID)
+ public String[] listSessions(final String connectionID) throws Exception
{
return server.listSessions(connectionID);
}
Modified: trunk/src/main/org/jboss/messaging/jms/server/management/jmx/impl/ReplicationAwareJMSServerControlWrapper.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/server/management/jmx/impl/ReplicationAwareJMSServerControlWrapper.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/src/main/org/jboss/messaging/jms/server/management/jmx/impl/ReplicationAwareJMSServerControlWrapper.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -300,22 +300,22 @@
return localControl.isStarted();
}
- public String[] listConnectionIDs()
+ public String[] listConnectionIDs() throws Exception
{
return localControl.listConnectionIDs();
}
- public String[] listRemoteAddresses()
+ public String[] listRemoteAddresses() throws Exception
{
return localControl.listRemoteAddresses();
}
- public String[] listRemoteAddresses(final String ipAddress)
+ public String[] listRemoteAddresses(final String ipAddress) throws Exception
{
return localControl.listRemoteAddresses(ipAddress);
}
- public String[] listSessions(final String connectionID)
+ public String[] listSessions(final String connectionID) throws Exception
{
return localControl.listSessions(connectionID);
}
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/JMSMessagingProxy.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/JMSMessagingProxy.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/JMSMessagingProxy.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -71,7 +71,7 @@
// Protected -----------------------------------------------------
- public Object retriveAttributeValue(String attributeName)
+ public Object retrieveAttributeValue(String attributeName)
{
try
{
@@ -86,7 +86,7 @@
}
}
- public Object invokOperation(String operationName, Object... args) throws Exception
+ public Object invokeOperation(String operationName, Object... args) throws Exception
{
Message m = session.createMessage();
JMSManagementHelper.putOperationInvocation(m, on, operationName, args);
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/JMSQueueControlUsingJMSTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/JMSQueueControlUsingJMSTest.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/JMSQueueControlUsingJMSTest.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -92,157 +92,157 @@
public boolean changeMessagePriority(String messageID, int newPriority) throws Exception
{
- return (Boolean)proxy.invokOperation("changeMessagePriority", messageID, newPriority);
+ return (Boolean)proxy.invokeOperation("changeMessagePriority", messageID, newPriority);
}
public int countMessages(String filter) throws Exception
{
- return (Integer)proxy.invokOperation("countMessages", filter);
+ return (Integer)proxy.invokeOperation("countMessages", filter);
}
public boolean expireMessage(String messageID) throws Exception
{
- return (Boolean)proxy.invokOperation("expireMessage", messageID);
+ return (Boolean)proxy.invokeOperation("expireMessage", messageID);
}
public int expireMessages(String filter) throws Exception
{
- return (Integer)proxy.invokOperation("expireMessages", filter);
+ return (Integer)proxy.invokeOperation("expireMessages", filter);
}
public int getConsumerCount()
{
- return (Integer)proxy.retriveAttributeValue("ConsumerCount");
+ return (Integer)proxy.retrieveAttributeValue("ConsumerCount");
}
public String getDeadLetterAddress()
{
- return (String)proxy.retriveAttributeValue("DeadLetterAddress");
+ return (String)proxy.retrieveAttributeValue("DeadLetterAddress");
}
public int getDeliveringCount()
{
- return (Integer)proxy.retriveAttributeValue("DeliveringCount");
+ return (Integer)proxy.retrieveAttributeValue("DeliveringCount");
}
public String getExpiryAddress()
{
- return (String)proxy.retriveAttributeValue("ExpiryAddress");
+ return (String)proxy.retrieveAttributeValue("ExpiryAddress");
}
public int getMessageCount()
{
- return (Integer)proxy.retriveAttributeValue("MessageCount");
+ return (Integer)proxy.retrieveAttributeValue("MessageCount");
}
public int getMessagesAdded()
{
- return (Integer)proxy.retriveAttributeValue("MessagesAdded");
+ return (Integer)proxy.retrieveAttributeValue("MessagesAdded");
}
public String getName()
{
- return (String)proxy.retriveAttributeValue("Name");
+ return (String)proxy.retrieveAttributeValue("Name");
}
public long getScheduledCount()
{
- return (Long)proxy.retriveAttributeValue("ScheduledCount");
+ return (Long)proxy.retrieveAttributeValue("ScheduledCount");
}
public boolean isDurable()
{
- return (Boolean)proxy.retriveAttributeValue("Durable");
+ return (Boolean)proxy.retrieveAttributeValue("Durable");
}
public boolean isTemporary()
{
- return (Boolean)proxy.retriveAttributeValue("Temporary");
+ return (Boolean)proxy.retrieveAttributeValue("Temporary");
}
public TabularData listAllMessages() throws Exception
{
- return (TabularData)proxy.invokOperation("listAllMessages");
+ return (TabularData)proxy.invokeOperation("listAllMessages");
}
public CompositeData listMessageCounter() throws Exception
{
- return (CompositeData)proxy.invokOperation("listMessageCounter");
+ return (CompositeData)proxy.invokeOperation("listMessageCounter");
}
public String listMessageCounterAsHTML() throws Exception
{
- return (String)proxy.invokOperation("listMessageCounterAsHTML");
+ return (String)proxy.invokeOperation("listMessageCounterAsHTML");
}
public TabularData listMessageCounterHistory() throws Exception
{
- return (TabularData)proxy.invokOperation("listMessageCounterHistory");
+ return (TabularData)proxy.invokeOperation("listMessageCounterHistory");
}
public String listMessageCounterHistoryAsHTML() throws Exception
{
- return (String)proxy.invokOperation("listMessageCounterHistoryAsHTML");
+ return (String)proxy.invokeOperation("listMessageCounterHistoryAsHTML");
}
public TabularData listMessages(String filter) throws Exception
{
- return (TabularData)proxy.invokOperation("listMessages", filter);
+ return (TabularData)proxy.invokeOperation("listMessages", filter);
}
public int moveAllMessages(String otherQueueName) throws Exception
{
- return (Integer)proxy.invokOperation("moveAllMessages", otherQueueName);
+ return (Integer)proxy.invokeOperation("moveAllMessages", otherQueueName);
}
public int moveMatchingMessages(String filter, String otherQueueName) throws Exception
{
- return (Integer)proxy.invokOperation("moveMatchingMessages", filter, otherQueueName);
+ return (Integer)proxy.invokeOperation("moveMatchingMessages", filter, otherQueueName);
}
public boolean moveMessage(String messageID, String otherQueueName) throws Exception
{
- return (Boolean)proxy.invokOperation("moveMessage", messageID, otherQueueName);
+ return (Boolean)proxy.invokeOperation("moveMessage", messageID, otherQueueName);
}
public int removeMatchingMessages(String filter) throws Exception
{
- return (Integer)proxy.invokOperation("removeMatchingMessages", filter);
+ return (Integer)proxy.invokeOperation("removeMatchingMessages", filter);
}
public boolean removeMessage(String messageID) throws Exception
{
- return (Boolean)proxy.invokOperation("removeMessage", messageID);
+ return (Boolean)proxy.invokeOperation("removeMessage", messageID);
}
public boolean sendMessageToDLQ(String messageID) throws Exception
{
- return (Boolean)proxy.invokOperation("sendMessageToDLQ", messageID);
+ return (Boolean)proxy.invokeOperation("sendMessageToDLQ", messageID);
}
public void setDeadLetterAddress(String deadLetterAddress) throws Exception
{
- proxy.invokOperation("setDeadLetterAddress", deadLetterAddress);
+ proxy.invokeOperation("setDeadLetterAddress", deadLetterAddress);
}
public void setExpiryAddress(String expiryAddress) throws Exception
{
- proxy.invokOperation("setExpiryAddress", expiryAddress);
+ proxy.invokeOperation("setExpiryAddress", expiryAddress);
}
public String getAddress()
{
- return (String)proxy.retriveAttributeValue("Address");
+ return (String)proxy.retrieveAttributeValue("Address");
}
public String getJNDIBinding()
{
- return (String)proxy.retriveAttributeValue("JNDIBinding");
+ return (String)proxy.retrieveAttributeValue("JNDIBinding");
}
public int removeAllMessages() throws Exception
{
- return (Integer)proxy.invokOperation("removeAllMessages");
+ return (Integer)proxy.invokeOperation("removeAllMessages");
}
};
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/JMSServerControlUsingJMSTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/JMSServerControlUsingJMSTest.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/JMSServerControlUsingJMSTest.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -98,14 +98,14 @@
public boolean closeConnectionsForAddress(final String ipAddress) throws Exception
{
- return (Boolean)proxy.invokOperation("closeConnectionsForAddress", ipAddress);
+ return (Boolean)proxy.invokeOperation("closeConnectionsForAddress", ipAddress);
}
public void createConnectionFactory(final String name,
final String connectorFactoryClassName,
final String jndiBinding) throws Exception
{
- proxy.invokOperation("createConnectionFactory", name, connectorFactoryClassName, jndiBinding);
+ proxy.invokeOperation("createConnectionFactory", name, connectorFactoryClassName, jndiBinding);
}
public void createConnectionFactory(final String name,
@@ -116,7 +116,7 @@
final boolean preAcknowledge,
final String jndiBinding) throws Exception
{
- proxy.invokOperation("createConnectionFactory",
+ proxy.invokeOperation("createConnectionFactory",
name,
connectorFactoryClassName,
blockOnAcknowledge,
@@ -152,7 +152,7 @@
final int maxRetriesAfterFailover,
final String jndiBinding) throws Exception
{
- proxy.invokOperation("createSimpleConnectionFactory",
+ proxy.invokeOperation("createSimpleConnectionFactory",
name,
connectorFactoryClassName,
connectionLoadBalancingPolicyClassName,
@@ -206,7 +206,7 @@
final int maxRetriesAfterFailover,
final String jndiBinding) throws Exception
{
- proxy.invokOperation("createConnectionFactory",
+ proxy.invokeOperation("createConnectionFactory",
name,
connectorConfigs,
connectionLoadBalancingPolicyClassName,
@@ -264,7 +264,7 @@
final int maxRetriesAfterFailover,
final String jndiBinding) throws Exception
{
- proxy.invokOperation("createConnectionFactory",
+ proxy.invokeOperation("createConnectionFactory",
name,
discoveryGroupName,
discoveryGroupAddress,
@@ -298,57 +298,57 @@
public boolean createQueue(final String name, final String jndiBinding) throws Exception
{
- return (Boolean)proxy.invokOperation("createQueue", name, jndiBinding);
+ return (Boolean)proxy.invokeOperation("createQueue", name, jndiBinding);
}
public boolean createTopic(final String name, final String jndiBinding) throws Exception
{
- return (Boolean)proxy.invokOperation("createTopic", name, jndiBinding);
+ return (Boolean)proxy.invokeOperation("createTopic", name, jndiBinding);
}
public void destroyConnectionFactory(final String name) throws Exception
{
- proxy.invokOperation("destroyConnectionFactory", name);
+ proxy.invokeOperation("destroyConnectionFactory", name);
}
public boolean destroyQueue(final String name) throws Exception
{
- return (Boolean)proxy.invokOperation("destroyQueue", name);
+ return (Boolean)proxy.invokeOperation("destroyQueue", name);
}
public boolean destroyTopic(final String name) throws Exception
{
- return (Boolean)proxy.invokOperation("destroyTopic", name);
+ return (Boolean)proxy.invokeOperation("destroyTopic", name);
}
public String getVersion()
{
- return (String)proxy.retriveAttributeValue("Version");
+ return (String)proxy.retrieveAttributeValue("Version");
}
public boolean isStarted()
{
- return (Boolean)proxy.retriveAttributeValue("Started");
+ return (Boolean)proxy.retrieveAttributeValue("Started");
}
public String[] listConnectionIDs() throws Exception
{
- return (String[])proxy.invokOperation("listConnectionIDs");
+ return (String[])proxy.invokeOperation("listConnectionIDs");
}
public String[] listRemoteAddresses() throws Exception
{
- return (String[])proxy.invokOperation("listRemoteAddresses");
+ return (String[])proxy.invokeOperation("listRemoteAddresses");
}
public String[] listRemoteAddresses(final String ipAddress) throws Exception
{
- return (String[])proxy.invokOperation("listRemoteAddresses", ipAddress);
+ return (String[])proxy.invokeOperation("listRemoteAddresses", ipAddress);
}
public String[] listSessions(final String connectionID) throws Exception
{
- return (String[])proxy.invokOperation("listSessions", connectionID);
+ return (String[])proxy.invokeOperation("listSessions", connectionID);
}
};
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/TopicControlUsingJMSTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/TopicControlUsingJMSTest.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/jms/management/TopicControlUsingJMSTest.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -92,92 +92,92 @@
{
public int countMessagesForSubscription(String clientID, String subscriptionName, String filter) throws Exception
{
- return (Integer)proxy.invokOperation("countMessagesForSubscription", clientID, subscriptionName, filter);
+ return (Integer)proxy.invokeOperation("countMessagesForSubscription", clientID, subscriptionName, filter);
}
public void dropAllSubscriptions() throws Exception
{
- proxy.invokOperation("dropAllSubscriptions");
+ proxy.invokeOperation("dropAllSubscriptions");
}
public void dropDurableSubscription(String clientID, String subscriptionName) throws Exception
{
- proxy.invokOperation("dropDurableSubscription", clientID, subscriptionName);
+ proxy.invokeOperation("dropDurableSubscription", clientID, subscriptionName);
}
public int getDurableMessagesCount()
{
- return (Integer)proxy.retriveAttributeValue("DurableMessagesCount");
+ return (Integer)proxy.retrieveAttributeValue("DurableMessagesCount");
}
public int getDurableSubcriptionsCount()
{
- return (Integer)proxy.retriveAttributeValue("DurableSubcriptionsCount");
+ return (Integer)proxy.retrieveAttributeValue("DurableSubcriptionsCount");
}
public int getNonDurableMessagesCount()
{
- return (Integer)proxy.retriveAttributeValue("NonDurableMessagesCount");
+ return (Integer)proxy.retrieveAttributeValue("NonDurableMessagesCount");
}
public int getNonDurableSubcriptionsCount()
{
- return (Integer)proxy.retriveAttributeValue("NonDurableSubcriptionsCount");
+ return (Integer)proxy.retrieveAttributeValue("NonDurableSubcriptionsCount");
}
public int getSubcriptionsCount()
{
- return (Integer)proxy.retriveAttributeValue("SubcriptionsCount");
+ return (Integer)proxy.retrieveAttributeValue("SubcriptionsCount");
}
public TabularData listAllSubscriptions() throws Exception
{
- return (TabularData)proxy.invokOperation("listAllSubscriptions");
+ return (TabularData)proxy.invokeOperation("listAllSubscriptions");
}
public TabularData listDurableSubscriptions() throws Exception
{
- return (TabularData)proxy.invokOperation("listDurableSubscriptions");
+ return (TabularData)proxy.invokeOperation("listDurableSubscriptions");
}
public TabularData listMessagesForSubscription(String queueName) throws Exception
{
- return (TabularData)proxy.invokOperation("listMessagesForSubscription", queueName);
+ return (TabularData)proxy.invokeOperation("listMessagesForSubscription", queueName);
}
public TabularData listNonDurableSubscriptions() throws Exception
{
- return (TabularData)proxy.invokOperation("listNonDurableSubscriptions");
+ return (TabularData)proxy.invokeOperation("listNonDurableSubscriptions");
}
public String getAddress()
{
- return (String)proxy.retriveAttributeValue("Address");
+ return (String)proxy.retrieveAttributeValue("Address");
}
public String getJNDIBinding()
{
- return (String)proxy.retriveAttributeValue("JNDIBinding");
+ return (String)proxy.retrieveAttributeValue("JNDIBinding");
}
public int getMessageCount() throws Exception
{
- return (Integer)proxy.retriveAttributeValue("MessageCount");
+ return (Integer)proxy.retrieveAttributeValue("MessageCount");
}
public String getName()
{
- return (String)proxy.retriveAttributeValue("Name");
+ return (String)proxy.retrieveAttributeValue("Name");
}
public boolean isTemporary()
{
- return (Boolean)proxy.retriveAttributeValue("Temporary");
+ return (Boolean)proxy.retrieveAttributeValue("Temporary");
}
public int removeAllMessages() throws Exception
{
- return (Integer)proxy.invokOperation("removeAllMessages");
+ return (Integer)proxy.invokeOperation("removeAllMessages");
}
};
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/MessagingServerControlTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/MessagingServerControlTest.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/MessagingServerControlTest.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -28,17 +28,23 @@
import javax.management.MBeanServer;
import javax.management.MBeanServerFactory;
+import javax.management.ObjectName;
import javax.management.openmbean.TabularData;
import org.jboss.messaging.core.config.Configuration;
import org.jboss.messaging.core.config.TransportConfiguration;
import org.jboss.messaging.core.config.impl.ConfigurationImpl;
import org.jboss.messaging.core.management.MessagingServerControlMBean;
+import org.jboss.messaging.core.management.ObjectNames;
+import org.jboss.messaging.core.management.QueueControlMBean;
import org.jboss.messaging.core.management.TransportConfigurationInfo;
+import org.jboss.messaging.core.messagecounter.impl.MessageCounterManagerImpl;
import org.jboss.messaging.core.remoting.impl.invm.InVMConnectorFactory;
import org.jboss.messaging.core.server.Messaging;
import org.jboss.messaging.core.server.MessagingService;
+import org.jboss.messaging.tests.util.RandomUtil;
import org.jboss.messaging.tests.util.UnitTestCase;
+import org.jboss.messaging.utils.SimpleString;
/**
* A QueueControlTest
@@ -58,44 +64,261 @@
private MessagingService service;
+ private MBeanServer mbeanServer;
+
+ private Configuration conf;
+
+ private TransportConfiguration connectorConfig;
+
// Static --------------------------------------------------------
// Constructors --------------------------------------------------
// Public --------------------------------------------------------
- public void testGetConnectors() throws Exception
+ public void testGetAttributes() throws Exception
{
- MBeanServer mbeanServer = MBeanServerFactory.createMBeanServer();
-
- TransportConfiguration connectorConfig = new TransportConfiguration(InVMConnectorFactory.class.getName(),
- new HashMap<String, Object>(),
- randomString());
+ MessagingServerControlMBean serverControl = createManagementControl();
- Configuration conf = new ConfigurationImpl();
- conf.setSecurityEnabled(false);
- conf.setJMXManagementEnabled(true);
- conf.getConnectorConfigurations().put(connectorConfig.getName(), connectorConfig);
- service = Messaging.newNullStorageMessagingService(conf, mbeanServer);
- service.start();
+ assertEquals(service.getServer().getVersion().getFullVersion(), serverControl.getVersion());
- MessagingServerControlMBean serverControl = ManagementControlHelper.createMessagingServerControl(mbeanServer);
+ assertEquals(conf.isClustered(), serverControl.isClustered());
+ assertEquals(conf.isAllowRouteWhenNoBindings(), serverControl.isAllowRouteWhenNoBindings());
+ assertEquals(conf.isPersistDeliveryCountBeforeDelivery(), serverControl.isPersistDeliveryCountBeforeDelivery());
+ assertEquals(conf.isBackup(), serverControl.isBackup());
+ assertEquals(conf.getQueueActivationTimeout(), serverControl.getQueueActivationTimeout());
+ assertEquals(conf.getScheduledThreadPoolMaxSize(), serverControl.getScheduledThreadPoolMaxSize());
+ assertEquals(conf.getSecurityInvalidationInterval(), serverControl.getSecurityInvalidationInterval());
+ assertEquals(conf.isSecurityEnabled(), serverControl.isSecurityEnabled());
+ assertEquals(conf.getInterceptorClassNames(), serverControl.getInterceptorClassNames());
+ assertEquals(conf.getConnectionScanPeriod(), serverControl.getConnectionScanPeriod());
+ assertEquals(conf.getConnectionTTLOverride(), serverControl.getConnectionTTLOverride());
- TabularData acceptorData = serverControl.getConnectors();
- assertNotNull(acceptorData);
- assertEquals(1, acceptorData.size());
+ // TODO
+ // assertEquals(conf.getBroadcastGroupConfigurations(), serverControl.getBroadcastGroupConfigurations());
+ // assertEquals(conf.getDiscoveryGroupConfigurations(), serverControl.getDiscoveryGroupConfigurations());
+ // assertEquals(conf.getBridgeConfigurations(), serverControl.getBridgeConfigurations());
+ // assertEquals(conf.getDivertConfigurations(), serverControl.getDivertConfigurations());
+ // assertEquals(conf.getClusterConfigurations(), serverControl.getClusterConfigurations());
+ // assertEquals(conf.getQueueConfigurations(), serverControl.getQueueConfigurations());
- TransportConfiguration[] connectorConfigurations = TransportConfigurationInfo.from(acceptorData);
+ assertEquals(conf.getBackupConnectorName(), serverControl.getBackupConnectorName());
+ assertEquals(conf.getManagementAddress().toString(), serverControl.getManagementAddress());
+ assertEquals(conf.getManagementNotificationAddress().toString(), serverControl.getManagementNotificationAddress());
+ assertEquals(conf.getManagementRequestTimeout(), serverControl.getManagementRequestTimeout());
+ assertEquals(conf.getIDCacheSize(), serverControl.getIDCacheSize());
+ assertEquals(conf.isPersistIDCache(), serverControl.isPersistIDCache());
+ assertEquals(conf.getBindingsDirectory(), serverControl.getBindingsDirectory());
+ assertEquals(conf.getJournalDirectory(), serverControl.getJournalDirectory());
+ assertEquals(conf.getJournalType().toString(), serverControl.getJournalType());
+ assertEquals(conf.isJournalSyncTransactional(), serverControl.isJournalSyncTransactional());
+ assertEquals(conf.isJournalSyncNonTransactional(), serverControl.isJournalSyncNonTransactional());
+ assertEquals(conf.getJournalFileSize(), serverControl.getJournalFileSize());
+ assertEquals(conf.getJournalMinFiles(), serverControl.getJournalMinFiles());
+ assertEquals(conf.getJournalMaxAIO(), serverControl.getJournalMaxAIO());
+ assertEquals(conf.getJournalBufferReuseSize(), serverControl.getJournalBufferReuseSize());
+ assertEquals(conf.isCreateBindingsDir(), serverControl.isCreateBindingsDir());
+ assertEquals(conf.isCreateJournalDir(), serverControl.isCreateJournalDir());
+ assertEquals(conf.getPagingMaxThreads(), serverControl.getPagingMaxThreads());
+ assertEquals(conf.getPagingDirectory(), serverControl.getPagingDirectory());
+ assertEquals(conf.getPagingMaxGlobalSizeBytes(), serverControl.getPagingMaxGlobalSizeBytes());
+ assertEquals(conf.getPagingGlobalWatermarkSize(), serverControl.getPagingGlobalWatermarkSize());
+ assertEquals(conf.getLargeMessagesDirectory(), serverControl.getLargeMessagesDirectory());
+ assertEquals(conf.isWildcardRoutingEnabled(), serverControl.isWildcardRoutingEnabled());
+ assertEquals(conf.getTransactionTimeout(), serverControl.getTransactionTimeout());
+ assertEquals(conf.isMessageCounterEnabled(), serverControl.isMessageCounterEnabled());
+ assertEquals(conf.getTransactionTimeoutScanPeriod(), serverControl.getTransactionTimeoutScanPeriod());
+ assertEquals(conf.getMessageExpiryScanPeriod(), serverControl.getMessageExpiryScanPeriod());
+ assertEquals(conf.getMessageExpiryThreadPriority(), serverControl.getMessageExpiryThreadPriority());
+ }
+
+ public void testGetConnectors() throws Exception
+ {
+ MessagingServerControlMBean serverControl = createManagementControl();
+
+ TabularData connectorData = serverControl.getConnectors();
+ assertNotNull(connectorData);
+ assertEquals(1, connectorData.size());
+
+ TransportConfiguration[] connectorConfigurations = TransportConfigurationInfo.from(connectorData);
assertEquals(1, connectorConfigurations.length);
assertEquals(connectorConfig.getName(), connectorConfigurations[0].getName());
}
+ public void testCreateAndDestroyQueue() throws Exception
+ {
+ SimpleString address = RandomUtil.randomSimpleString();
+ SimpleString name = RandomUtil.randomSimpleString();
+
+ MessagingServerControlMBean serverControl = createManagementControl();
+
+ checkNoResource(ObjectNames.getQueueObjectName(address, name));
+
+ serverControl.createQueue(address.toString(), name.toString());
+
+ checkResource(ObjectNames.getQueueObjectName(address, name));
+ QueueControlMBean queueControl = ManagementControlHelper.createQueueControl(address, name, mbeanServer);
+ assertEquals(address.toString(), queueControl.getAddress());
+ assertEquals(name.toString(), queueControl.getName());
+ assertNull(queueControl.getFilter());
+ assertEquals(true, queueControl.isDurable());
+ assertEquals(false, queueControl.isTemporary());
+
+ serverControl.destroyQueue(name.toString());
+
+ checkNoResource(ObjectNames.getQueueObjectName(address, name));
+ }
+
+ public void testCreateAndDestroyQueue_2() throws Exception
+ {
+ SimpleString address = RandomUtil.randomSimpleString();
+ SimpleString name = RandomUtil.randomSimpleString();
+ String filter = "color = 'green'";
+ boolean durable = true;
+
+ MessagingServerControlMBean serverControl = createManagementControl();
+
+ checkNoResource(ObjectNames.getQueueObjectName(address, name));
+
+ serverControl.createQueue(address.toString(), name.toString(), filter, durable);
+
+ checkResource(ObjectNames.getQueueObjectName(address, name));
+ QueueControlMBean queueControl = ManagementControlHelper.createQueueControl(address, name, mbeanServer);
+ assertEquals(address.toString(), queueControl.getAddress());
+ assertEquals(name.toString(), queueControl.getName());
+ assertEquals(filter, queueControl.getFilter());
+ assertEquals(durable, queueControl.isDurable());
+ assertEquals(false, queueControl.isTemporary());
+
+ serverControl.destroyQueue(name.toString());
+
+ checkNoResource(ObjectNames.getQueueObjectName(address, name));
+ }
+
+ public void testCreateAndDestroyQueueWithNullFilter() throws Exception
+ {
+ SimpleString address = RandomUtil.randomSimpleString();
+ SimpleString name = RandomUtil.randomSimpleString();
+ String filter = null;
+ boolean durable = true;
+
+ MessagingServerControlMBean serverControl = createManagementControl();
+
+ checkNoResource(ObjectNames.getQueueObjectName(address, name));
+
+ serverControl.createQueue(address.toString(), name.toString(), filter, durable);
+
+ checkResource(ObjectNames.getQueueObjectName(address, name));
+ QueueControlMBean queueControl = ManagementControlHelper.createQueueControl(address, name, mbeanServer);
+ assertEquals(address.toString(), queueControl.getAddress());
+ assertEquals(name.toString(), queueControl.getName());
+ assertNull(queueControl.getFilter());
+ assertEquals(durable, queueControl.isDurable());
+ assertEquals(false, queueControl.isTemporary());
+
+ serverControl.destroyQueue(name.toString());
+
+ checkNoResource(ObjectNames.getQueueObjectName(address, name));
+ }
+
+ public void testMessageCounterMaxDayCount() throws Exception
+ {
+ MessagingServerControlMBean serverControl = createManagementControl();
+
+ assertEquals(MessageCounterManagerImpl.DEFAULT_MAX_DAY_COUNT, serverControl.getMessageCounterMaxDayCount());
+
+ int newCount = 100;
+ serverControl.setMessageCounterMaxDayCount(newCount);
+
+ assertEquals(newCount, serverControl.getMessageCounterMaxDayCount());
+
+ try
+ {
+ serverControl.setMessageCounterMaxDayCount(-1);
+ fail();
+ }
+ catch (Exception e)
+ {
+ }
+
+ try
+ {
+ serverControl.setMessageCounterMaxDayCount(0);
+ fail();
+ }
+ catch (Exception e)
+ {
+ }
+
+ assertEquals(newCount, serverControl.getMessageCounterMaxDayCount());
+ }
+
+ public void testGetMessageCounterSamplePeriod() throws Exception
+ {
+ MessagingServerControlMBean serverControl = createManagementControl();
+
+ assertEquals(MessageCounterManagerImpl.DEFAULT_SAMPLE_PERIOD, serverControl.getMessageCounterSamplePeriod());
+
+ long newSample = 20000;
+ serverControl.setMessageCounterSamplePeriod(newSample);
+
+ assertEquals(newSample, serverControl.getMessageCounterSamplePeriod());
+
+ try
+ {
+ serverControl.setMessageCounterSamplePeriod(-1);
+ fail();
+ }
+ catch (Exception e)
+ {
+ }
+
+ try
+ {
+ serverControl.setMessageCounterSamplePeriod(0);
+ fail();
+ }
+ catch (Exception e)
+ {
+ }
+
+ try
+ {
+ serverControl.setMessageCounterSamplePeriod(MessageCounterManagerImpl.MIN_SAMPLE_PERIOD - 1);
+ fail();
+ }
+ catch (Exception e)
+ {
+ }
+
+ assertEquals(newSample, serverControl.getMessageCounterSamplePeriod());
+ }
+
// Package protected ---------------------------------------------
// Protected -----------------------------------------------------
@Override
+ protected void setUp() throws Exception
+ {
+ super.setUp();
+
+ mbeanServer = MBeanServerFactory.createMBeanServer();
+
+ connectorConfig = new TransportConfiguration(InVMConnectorFactory.class.getName(),
+ new HashMap<String, Object>(),
+ randomString());
+
+ conf = new ConfigurationImpl();
+ conf.setSecurityEnabled(false);
+ conf.setJMXManagementEnabled(true);
+ service = Messaging.newNullStorageMessagingService(conf, mbeanServer);
+ conf.getConnectorConfigurations().put(connectorConfig.getName(), connectorConfig);
+ service.start();
+ }
+
+ @Override
protected void tearDown() throws Exception
{
if (service != null)
@@ -106,8 +329,23 @@
super.tearDown();
}
+ protected MessagingServerControlMBean createManagementControl() throws Exception
+ {
+ return ManagementControlHelper.createMessagingServerControl(mbeanServer);
+ }
+
// Private -------------------------------------------------------
+ private void checkNoResource(ObjectName on)
+ {
+ assertFalse(mbeanServer.isRegistered(on));
+ }
+
+ private void checkResource(ObjectName on)
+ {
+ assertTrue(mbeanServer.isRegistered(on));
+ }
+
// Inner classes -------------------------------------------------
}
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/core/CoreAddressControlTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/core/CoreAddressControlTest.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/core/CoreAddressControlTest.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -59,27 +59,27 @@
public void addRole(String name, boolean create, boolean read, boolean write) throws Exception
{
- proxy.invokOperation("addRole", name, create, read, write);
+ proxy.invokeOperation("addRole", name, create, read, write);
}
public String getAddress()
{
- return (String)proxy.retriveAttributeValue("Address");
+ return (String)proxy.retrieveAttributeValue("Address");
}
public String[] getQueueNames() throws Exception
{
- return (String[])proxy.retriveAttributeValue("QueueNames");
+ return (String[])proxy.retrieveAttributeValue("QueueNames");
}
public TabularData getRoles() throws Exception
{
- return (TabularData)proxy.retriveAttributeValue("Roles");
+ return (TabularData)proxy.retrieveAttributeValue("Roles");
}
public void removeRole(String name) throws Exception
{
- proxy.invokOperation("removeRole", name);
+ proxy.invokeOperation("removeRole", name);
}
};
}
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/core/CoreMessagingProxy.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/core/CoreMessagingProxy.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/core/CoreMessagingProxy.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -72,7 +72,7 @@
// Protected -----------------------------------------------------
- public Object retriveAttributeValue(String attributeName)
+ public Object retrieveAttributeValue(String attributeName)
{
ClientMessage m = session.createClientMessage(false);
ManagementHelper.putAttribute(m, on, attributeName);
@@ -88,7 +88,7 @@
}
}
- public Object invokOperation(String operationName, Object... args) throws Exception
+ public Object invokeOperation(String operationName, Object... args) throws Exception
{
ClientMessage m = session.createClientMessage(false);
ManagementHelper.putOperationInvocation(m, on, operationName, args);
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/core/CoreQueueControlTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/core/CoreQueueControlTest.java 2009-03-18 23:02:43 UTC (rev 6113)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/core/CoreQueueControlTest.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -62,172 +62,172 @@
public boolean changeMessagePriority(long messageID, int newPriority) throws Exception
{
- return (Boolean)proxy.invokOperation("changeMessagePriority", messageID, newPriority);
+ return (Boolean)proxy.invokeOperation("changeMessagePriority", messageID, newPriority);
}
public int countMessages(String filter) throws Exception
{
- return (Integer)proxy.invokOperation("countMessages", filter);
+ return (Integer)proxy.invokeOperation("countMessages", filter);
}
public boolean expireMessage(long messageID) throws Exception
{
- return (Boolean)proxy.invokOperation("expireMessage", messageID);
+ return (Boolean)proxy.invokeOperation("expireMessage", messageID);
}
public int expireMessages(String filter) throws Exception
{
- return (Integer)proxy.invokOperation("expireMessages", filter);
+ return (Integer)proxy.invokeOperation("expireMessages", filter);
}
public String getAddress()
{
- return (String)proxy.retriveAttributeValue("Address");
+ return (String)proxy.retrieveAttributeValue("Address");
}
public int getConsumerCount()
{
- return (Integer)proxy.retriveAttributeValue("ConsumerCount");
+ return (Integer)proxy.retrieveAttributeValue("ConsumerCount");
}
public String getDeadLetterAddress()
{
- return (String)proxy.retriveAttributeValue("DeadLetterAddress");
+ return (String)proxy.retrieveAttributeValue("DeadLetterAddress");
}
public int getDeliveringCount()
{
- return (Integer)proxy.retriveAttributeValue("DeliveringCount");
+ return (Integer)proxy.retrieveAttributeValue("DeliveringCount");
}
public String getExpiryAddress()
{
- return (String)proxy.retriveAttributeValue("ExpiryAddress");
+ return (String)proxy.retrieveAttributeValue("ExpiryAddress");
}
public String getFilter()
{
- return (String)proxy.retriveAttributeValue("Filter");
+ return (String)proxy.retrieveAttributeValue("Filter");
}
public int getMessageCount()
{
- return (Integer)proxy.retriveAttributeValue("MessageCount");
+ return (Integer)proxy.retrieveAttributeValue("MessageCount");
}
public int getMessagesAdded()
{
- return (Integer)proxy.retriveAttributeValue("MessagesAdded");
+ return (Integer)proxy.retrieveAttributeValue("MessagesAdded");
}
public String getName()
{
- return (String)proxy.retriveAttributeValue("Name");
+ return (String)proxy.retrieveAttributeValue("Name");
}
public long getPersistenceID()
{
- return (Long)proxy.retriveAttributeValue("PersistenceID");
+ return (Long)proxy.retrieveAttributeValue("PersistenceID");
}
public long getScheduledCount()
{
- return (Long)proxy.retriveAttributeValue("ScheduledCount");
+ return (Long)proxy.retrieveAttributeValue("ScheduledCount");
}
public boolean isBackup()
{
- return (Boolean)proxy.retriveAttributeValue("Backup");
+ return (Boolean)proxy.retrieveAttributeValue("Backup");
}
public boolean isDurable()
{
- return (Boolean)proxy.retriveAttributeValue("Durable");
+ return (Boolean)proxy.retrieveAttributeValue("Durable");
}
public boolean isTemporary()
{
- return (Boolean)proxy.retriveAttributeValue("Temporary");
+ return (Boolean)proxy.retrieveAttributeValue("Temporary");
}
public TabularData listAllMessages() throws Exception
{
- return (TabularData)proxy.invokOperation("listAllMessages");
+ return (TabularData)proxy.invokeOperation("listAllMessages");
}
public CompositeData listMessageCounter() throws Exception
{
- return (CompositeData)proxy.invokOperation("listMessageCounter");
+ return (CompositeData)proxy.invokeOperation("listMessageCounter");
}
public String listMessageCounterAsHTML() throws Exception
{
- return (String)proxy.invokOperation("listMessageCounterAsHTML");
+ return (String)proxy.invokeOperation("listMessageCounterAsHTML");
}
public TabularData listMessageCounterHistory() throws Exception
{
- return (TabularData)proxy.invokOperation("listMessageCounterHistory");
+ return (TabularData)proxy.invokeOperation("listMessageCounterHistory");
}
public String listMessageCounterHistoryAsHTML() throws Exception
{
- return (String)proxy.invokOperation("listMessageCounterHistoryAsHTML");
+ return (String)proxy.invokeOperation("listMessageCounterHistoryAsHTML");
}
public TabularData listMessages(String filter) throws Exception
{
- return (TabularData)proxy.invokOperation("listMessages", filter);
+ return (TabularData)proxy.invokeOperation("listMessages", filter);
}
public TabularData listScheduledMessages() throws Exception
{
- return (TabularData)proxy.invokOperation("listScheduledMessages");
+ return (TabularData)proxy.invokeOperation("listScheduledMessages");
}
public int moveAllMessages(String otherQueueName) throws Exception
{
- return (Integer)proxy.invokOperation("moveAllMessages", otherQueueName);
+ return (Integer)proxy.invokeOperation("moveAllMessages", otherQueueName);
}
public int moveMatchingMessages(String filter, String otherQueueName) throws Exception
{
- return (Integer)proxy.invokOperation("moveMatchingMessages", filter, otherQueueName);
+ return (Integer)proxy.invokeOperation("moveMatchingMessages", filter, otherQueueName);
}
public boolean moveMessage(long messageID, String otherQueueName) throws Exception
{
- return (Boolean)proxy.invokOperation("moveMessage", messageID, otherQueueName);
+ return (Boolean)proxy.invokeOperation("moveMessage", messageID, otherQueueName);
}
public int removeAllMessages() throws Exception
{
- return (Integer)proxy.invokOperation("removeAllMessages");
+ return (Integer)proxy.invokeOperation("removeAllMessages");
}
public int removeMatchingMessages(String filter) throws Exception
{
- return (Integer)proxy.invokOperation("removeMatchingMessages", filter);
+ return (Integer)proxy.invokeOperation("removeMatchingMessages", filter);
}
public boolean removeMessage(long messageID) throws Exception
{
- return (Boolean)proxy.invokOperation("removeMessage", messageID);
+ return (Boolean)proxy.invokeOperation("removeMessage", messageID);
}
public boolean sendMessageToDeadLetterAddress(long messageID) throws Exception
{
- return (Boolean)proxy.invokOperation("sendMessageToDeadLetterAddress", messageID);
+ return (Boolean)proxy.invokeOperation("sendMessageToDeadLetterAddress", messageID);
}
public void setDeadLetterAddress(String deadLetterAddress) throws Exception
{
- proxy.invokOperation("setDeadLetterAddress", deadLetterAddress);
+ proxy.invokeOperation("setDeadLetterAddress", deadLetterAddress);
}
public void setExpiryAddress(String expiryAddres) throws Exception
{
- proxy.invokOperation("setExpiryAddress", expiryAddres);
+ proxy.invokeOperation("setExpiryAddress", expiryAddres);
}
};
}
Added: trunk/tests/src/org/jboss/messaging/tests/integration/management/core/MessagingServerControlUsingCoreTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/core/MessagingServerControlUsingCoreTest.java (rev 0)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/core/MessagingServerControlUsingCoreTest.java 2009-03-19 14:50:18 UTC (rev 6114)
@@ -0,0 +1,419 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2005-2009, 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.tests.integration.management.core;
+
+import java.util.List;
+
+import javax.management.openmbean.TabularData;
+
+import org.jboss.messaging.core.client.ClientSession;
+import org.jboss.messaging.core.client.ClientSessionFactory;
+import org.jboss.messaging.core.client.impl.ClientSessionFactoryImpl;
+import org.jboss.messaging.core.config.Configuration;
+import org.jboss.messaging.core.config.TransportConfiguration;
+import org.jboss.messaging.core.management.MessagingServerControlMBean;
+import org.jboss.messaging.core.management.ObjectNames;
+import org.jboss.messaging.core.remoting.impl.invm.InVMConnectorFactory;
+import org.jboss.messaging.tests.integration.management.MessagingServerControlTest;
+
+/**
+ * A MessagingServerControlUsingCoreTest
+ *
+ * @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
+ */
+public class MessagingServerControlUsingCoreTest extends MessagingServerControlTest
+{
+
+ // Constants -----------------------------------------------------
+
+ // Attributes ----------------------------------------------------
+
+ // Static --------------------------------------------------------
+
+ // Constructors --------------------------------------------------
+
+ // Public --------------------------------------------------------
+
+ // MessagingServerControlTest overrides --------------------------
+
+ private ClientSession session;
+
+ @Override
+ protected void setUp() throws Exception
+ {
+ super.setUp();
+
+ ClientSessionFactory sf = new ClientSessionFactoryImpl(new TransportConfiguration(InVMConnectorFactory.class.getName()));
+ session = sf.createSession(false, true, true);
+ session.start();
+
+ }
+
+ @Override
+ protected void tearDown() throws Exception
+ {
+ session.close();
+
+ super.tearDown();
+ }
+
+ @Override
+ protected MessagingServerControlMBean createManagementControl() throws Exception
+ {
+
+ return new MessagingServerControlMBean()
+ {
+ private final CoreMessagingProxy proxy = new CoreMessagingProxy(session,
+ ObjectNames.getMessagingServerObjectName());
+
+ public boolean closeConnectionsForAddress(String ipAddress) throws Exception
+ {
+ return (Boolean)proxy.invokeOperation("closeConnectionsForAddress", ipAddress);
+ }
+
+ public boolean commitPreparedTransaction(String transactionAsBase64) throws Exception
+ {
+ return (Boolean)proxy.invokeOperation("commitPreparedTransaction", transactionAsBase64);
+ }
+
+ public void createQueue(String address, String name) throws Exception
+ {
+ proxy.invokeOperation("createQueue", address, name);
+ }
+
+ public void createQueue(String address, String name, String filter, boolean durable) throws Exception
+ {
+ proxy.invokeOperation("createQueue", address, name, filter, durable);
+ }
+
+ public void destroyQueue(String name) throws Exception
+ {
+ proxy.invokeOperation("destroyQueue", name);
+ }
+
+ public void disableMessageCounters() throws Exception
+ {
+ proxy.invokeOperation("disableMessageCounters");
+ }
+
+ public void enableMessageCounters() throws Exception
+ {
+ proxy.invokeOperation("enableMessageCounters");
+ }
+
+ public String getBackupConnectorName()
+ {
+ return (String)proxy.retrieveAttributeValue("BackupConnectorName");
+ }
+
+ public String getBindingsDirectory()
+ {
+ return (String)proxy.retrieveAttributeValue("BindingsDirectory");
+ }
+
+ public Configuration getConfiguration()
+ {
+ return (Configuration)proxy.retrieveAttributeValue("Configuration");
+ }
+
+ public int getConnectionCount()
+ {
+ return (Integer)proxy.retrieveAttributeValue("ConnectionCount");
+ }
+
+ public long getConnectionScanPeriod()
+ {
+ return (Long)proxy.retrieveAttributeValue("ConnectionScanPeriod");
+ }
+
+ public long getConnectionTTLOverride()
+ {
+ return (Long)proxy.retrieveAttributeValue("ConnectionTTLOverride");
+ }
+
+ public TabularData getConnectors() throws Exception
+ {
+ return (TabularData)proxy.retrieveAttributeValue("Connectors");
+ }
+
+ public int getIDCacheSize()
+ {
+ return (Integer)proxy.retrieveAttributeValue("IDCacheSize");
+ }
+
+ public List<String> getInterceptorClassNames()
+ {
+ return (List<String>)proxy.retrieveAttributeValue("InterceptorClassNames");
+ }
+
+ public int getJournalBufferReuseSize()
+ {
+ return (Integer)proxy.retrieveAttributeValue("JournalBufferReuseSize");
+ }
+
+ public String getJournalDirectory()
+ {
+ return (String)proxy.retrieveAttributeValue("JournalDirectory");
+ }
+
+ public int getJournalFileSize()
+ {
+ return (Integer)proxy.retrieveAttributeValue("JournalFileSize");
+ }
+
+ public int getJournalMaxAIO()
+ {
+ return (Integer)proxy.retrieveAttributeValue("JournalMaxAIO");
+ }
+
+ public int getJournalMinFiles()
+ {
+ return (Integer)proxy.retrieveAttributeValue("JournalMinFiles");
+ }
+
+ public String getJournalType()
+ {
+ return (String)proxy.retrieveAttributeValue("JournalType");
+ }
+
+ public String getLargeMessagesDirectory()
+ {
+ return (String)proxy.retrieveAttributeValue("LargeMessagesDirectory");
+ }
+
+ public String getManagementAddress()
+ {
+ return (String)proxy.retrieveAttributeValue("ManagementAddress");
+ }
+
+ public String getManagementNotificationAddress()
+ {
+ return (String)proxy.retrieveAttributeValue("ManagementNotificationAddress");
+ }
+
+ public long getManagementRequestTimeout()
+ {
+ return (Long)proxy.retrieveAttributeValue("ManagementRequestTimeout");
+ }
+
+ public int getMessageCounterMaxDayCount()
+ {
+ return (Integer)proxy.retrieveAttributeValue("MessageCounterMaxDayCount");
+ }
+
+ public long getMessageCounterSamplePeriod()
+ {
+ return (Long)proxy.retrieveAttributeValue("MessageCounterSamplePeriod");
+ }
+
+ public long getMessageExpiryScanPeriod()
+ {
+ return (Long)proxy.retrieveAttributeValue("MessageExpiryScanPeriod");
+ }
+
+ public long getMessageExpiryThreadPriority()
+ {
+ return (Long)proxy.retrieveAttributeValue("MessageExpiryThreadPriority");
+ }
+
+ public String getPagingDirectory()
+ {
+ return (String)proxy.retrieveAttributeValue("PagingDirectory");
+ }
+
+ public int getPagingGlobalWatermarkSize()
+ {
+ return (Integer)proxy.retrieveAttributeValue("PagingGlobalWatermarkSize");
+ }
+
+ public long getPagingMaxGlobalSizeBytes()
+ {
+ return (Long)proxy.retrieveAttributeValue("PagingMaxGlobalSizeBytes");
+ }
+
+ public int getPagingMaxThreads()
+ {
+ return (Integer)proxy.retrieveAttributeValue("PagingMaxThreads");
+ }
+
+ public long getQueueActivationTimeout()
+ {
+ return (Long)proxy.retrieveAttributeValue("QueueActivationTimeout");
+ }
+
+ public int getScheduledThreadPoolMaxSize()
+ {
+ return (Integer)proxy.retrieveAttributeValue("ScheduledThreadPoolMaxSize");
+ }
+
+ public long getSecurityInvalidationInterval()
+ {
+ return (Long)proxy.retrieveAttributeValue("SecurityInvalidationInterval");
+ }
+
+ public long getTransactionTimeout()
+ {
+ return (Long)proxy.retrieveAttributeValue("TransactionTimeout");
+ }
+
+ public long getTransactionTimeoutScanPeriod()
+ {
+ return (Long)proxy.retrieveAttributeValue("TransactionTimeoutScanPeriod");
+ }
+
+ public String getVersion()
+ {
+ return (String)proxy.retrieveAttributeValue("Version");
+ }
+
+ public boolean isAllowRouteWhenNoBindings()
+ {
+ return (Boolean)proxy.retrieveAttributeValue("AllowRouteWhenNoBindings");
+ }
+
+ public boolean isBackup()
+ {
+ return (Boolean)proxy.retrieveAttributeValue("Backup");
+ }
+
+ public boolean isClustered()
+ {
+ return (Boolean)proxy.retrieveAttributeValue("Clustered");
+ }
+
+ public boolean isCreateBindingsDir()
+ {
+ return (Boolean)proxy.retrieveAttributeValue("CreateBindingsDir");
+ }
+
+ public boolean isCreateJournalDir()
+ {
+ return (Boolean)proxy.retrieveAttributeValue("CreateJournalDir");
+ }
+
+ public boolean isJournalSyncNonTransactional()
+ {
+ return (Boolean)proxy.retrieveAttributeValue("JournalSyncNonTransactional");
+ }
+
+ public boolean isJournalSyncTransactional()
+ {
+ return (Boolean)proxy.retrieveAttributeValue("JournalSyncTransactional");
+ }
+
+ public boolean isMessageCounterEnabled()
+ {
+ return (Boolean)proxy.retrieveAttributeValue("MessageCounterEnabled");
+ }
+
+ public boolean isPersistDeliveryCountBeforeDelivery()
+ {
+ return (Boolean)proxy.retrieveAttributeValue("PersistDeliveryCountBeforeDelivery");
+ }
+
+ public boolean isPersistIDCache()
+ {
+ return (Boolean)proxy.retrieveAttributeValue("PersistIDCache");
+ }
+
+ public boolean isSecurityEnabled()
+ {
+ return (Boolean)proxy.retrieveAttributeValue("SecurityEnabled");
+ }
+
+ public boolean isStarted()
+ {
+ return (Boolean)proxy.retrieveAttributeValue("Started");
+ }
+
+ public boolean isWildcardRoutingEnabled()
+ {
+ return (Boolean)proxy.retrieveAttributeValue("WildcardRoutingEnabled");
+ }
+
+ public String[] listConnectionIDs() throws Exception
+ {
+ return (String[])proxy.invokeOperation("listConnectionIDs");
+ }
+
+ public String[] listPreparedTransactions() throws Exception
+ {
+ return (String[])proxy.invokeOperation("listPreparedTransactions");
+ }
+
+ public String[] listRemoteAddresses() throws Exception
+ {
+ return (String[])proxy.invokeOperation("listRemoteAddresses");
+ }
+
+ public String[] listRemoteAddresses(String ipAddress) throws Exception
+ {
+ return (String[])proxy.invokeOperation("listRemoteAddresses", ipAddress);
+ }
+
+ public String[] listSessions(String connectionID) throws Exception
+ {
+ return (String[])proxy.invokeOperation("listSessions", connectionID);
+ }
+
+ public void resetAllMessageCounterHistories() throws Exception
+ {
+ proxy.invokeOperation("resetAllMessageCounterHistories");
+ }
+
+ public void resetAllMessageCounters() throws Exception
+ {
+ proxy.invokeOperation("resetAllMessageCounters");
+ }
+
+ public boolean rollbackPreparedTransaction(String transactionAsBase64) throws Exception
+ {
+ return (Boolean)proxy.invokeOperation("rollbackPreparedTransaction", transactionAsBase64);
+ }
+
+ public void sendQueueInfoToQueue(String queueName, String address) throws Exception
+ {
+ proxy.invokeOperation("sendQueueInfoToQueue", queueName, address);
+ }
+
+ public void setMessageCounterMaxDayCount(int count) throws Exception
+ {
+ proxy.invokeOperation("setMessageCounterMaxDayCount", count);
+ }
+
+ public void setMessageCounterSamplePeriod(long newPeriod) throws Exception
+ {
+ proxy.invokeOperation("setMessageCounterSamplePeriod", newPeriod);
+ }
+
+ };
+ }
+ // Package protected ---------------------------------------------
+
+ // Protected -----------------------------------------------------
+
+ // Private -------------------------------------------------------
+
+ // Inner classes -------------------------------------------------
+
+}
More information about the jboss-cvs-commits
mailing list