[hornetq-commits] JBoss hornetq SVN: r7973 - in trunk: tests/src/org/hornetq/tests/integration/management and 1 other directory.
do-not-reply at jboss.org
do-not-reply at jboss.org
Sat Sep 19 11:48:25 EDT 2009
Author: timfox
Date: 2009-09-19 11:48:25 -0400 (Sat, 19 Sep 2009)
New Revision: 7973
Modified:
trunk/src/main/org/hornetq/core/management/impl/QueueControlImpl.java
trunk/tests/src/org/hornetq/tests/integration/management/ManagementControlHelper.java
trunk/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java
trunk/tests/src/org/hornetq/tests/integration/management/QueueControlUsingCoreTest.java
Log:
fixed test
Modified: trunk/src/main/org/hornetq/core/management/impl/QueueControlImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/management/impl/QueueControlImpl.java 2009-09-18 16:59:05 UTC (rev 7972)
+++ trunk/src/main/org/hornetq/core/management/impl/QueueControlImpl.java 2009-09-19 15:48:25 UTC (rev 7973)
@@ -413,19 +413,16 @@
public void pause()
{
- log.info("calling pause");
queue.pause();
}
public void resume()
{
- log.info("calling resume");
queue.resume();
}
public boolean isPaused() throws Exception
{
- log.info("calling isPaused");
return queue.isPaused();
}
Modified: trunk/tests/src/org/hornetq/tests/integration/management/ManagementControlHelper.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/management/ManagementControlHelper.java 2009-09-18 16:59:05 UTC (rev 7972)
+++ trunk/tests/src/org/hornetq/tests/integration/management/ManagementControlHelper.java 2009-09-19 15:48:25 UTC (rev 7973)
@@ -52,65 +52,57 @@
public static AcceptorControl createAcceptorControl(String name, MBeanServer mbeanServer) throws Exception
{
- return (AcceptorControl)createProxy(ObjectNames.getAcceptorObjectName(name),
- AcceptorControl.class,
- mbeanServer);
+ return (AcceptorControl)createProxy(ObjectNames.getAcceptorObjectName(name), AcceptorControl.class, mbeanServer);
}
public static BroadcastGroupControl createBroadcastGroupControl(String name, MBeanServer mbeanServer) throws Exception
{
return (BroadcastGroupControl)createProxy(ObjectNames.getBroadcastGroupObjectName(name),
- BroadcastGroupControl.class,
- mbeanServer);
+ BroadcastGroupControl.class,
+ mbeanServer);
}
public static DiscoveryGroupControl createDiscoveryGroupControl(String name, MBeanServer mbeanServer) throws Exception
{
return (DiscoveryGroupControl)createProxy(ObjectNames.getDiscoveryGroupObjectName(name),
- DiscoveryGroupControl.class,
- mbeanServer);
+ DiscoveryGroupControl.class,
+ mbeanServer);
}
public static BridgeControl createBridgeControl(String name, MBeanServer mbeanServer) throws Exception
{
- return (BridgeControl)createProxy(ObjectNames.getBridgeObjectName(name),
- BridgeControl.class,
- mbeanServer);
+ return (BridgeControl)createProxy(ObjectNames.getBridgeObjectName(name), BridgeControl.class, mbeanServer);
}
public static DivertControl createDivertControl(String name, MBeanServer mbeanServer) throws Exception
{
return (DivertControl)createProxy(ObjectNames.getDivertObjectName(new SimpleString(name)),
- DivertControl.class,
- mbeanServer);
+ DivertControl.class,
+ mbeanServer);
}
public static ClusterConnectionControl createClusterConnectionControl(String name, MBeanServer mbeanServer) throws Exception
{
return (ClusterConnectionControl)createProxy(ObjectNames.getClusterConnectionObjectName(name),
- ClusterConnectionControl.class,
- mbeanServer);
+ ClusterConnectionControl.class,
+ mbeanServer);
}
public static HornetQServerControl createHornetQServerControl(MBeanServer mbeanServer) throws Exception
{
return (HornetQServerControl)createProxy(ObjectNames.getHornetQServerObjectName(),
- HornetQServerControl.class,
- mbeanServer);
+ HornetQServerControl.class,
+ mbeanServer);
}
public static QueueControl createQueueControl(SimpleString address, SimpleString name, MBeanServer mbeanServer) throws Exception
{
- return (QueueControl)createProxy(ObjectNames.getQueueObjectName(address, name),
- QueueControl.class,
- mbeanServer);
+ return (QueueControl)createProxy(ObjectNames.getQueueObjectName(address, name), QueueControl.class, mbeanServer);
}
public static AddressControl createAddressControl(SimpleString address, MBeanServer mbeanServer) throws Exception
{
- return (AddressControl)createProxy(ObjectNames.getAddressObjectName(address),
- AddressControl.class,
- mbeanServer);
+ return (AddressControl)createProxy(ObjectNames.getAddressObjectName(address), AddressControl.class, mbeanServer);
}
public static JMSQueueControl createJMSQueueControl(Queue queue, MBeanServer mbeanServer) throws Exception
@@ -120,30 +112,26 @@
public static JMSQueueControl createJMSQueueControl(String name, MBeanServer mbeanServer) throws Exception
{
- return (JMSQueueControl)createProxy(ObjectNames.getJMSQueueObjectName(name),
- JMSQueueControl.class,
- mbeanServer);
+ return (JMSQueueControl)createProxy(ObjectNames.getJMSQueueObjectName(name), JMSQueueControl.class, mbeanServer);
}
public static JMSServerControl createJMSServerControl(MBeanServer mbeanServer) throws Exception
{
- return (JMSServerControl)createProxy(ObjectNames.getJMSServerObjectName(),
- JMSServerControl.class,
- mbeanServer);
+ return (JMSServerControl)createProxy(ObjectNames.getJMSServerObjectName(), JMSServerControl.class, mbeanServer);
}
public static ConnectionFactoryControl createConnectionFactoryControl(String name, MBeanServer mbeanServer) throws Exception
{
return (ConnectionFactoryControl)createProxy(ObjectNames.getConnectionFactoryObjectName(name),
- ConnectionFactoryControl.class,
- mbeanServer);
+ ConnectionFactoryControl.class,
+ mbeanServer);
}
public static TopicControl createTopicControl(Topic topic, MBeanServer mbeanServer) throws Exception
{
return (TopicControl)createProxy(ObjectNames.getJMSTopicObjectName(topic.getTopicName()),
- TopicControl.class,
- mbeanServer);
+ TopicControl.class,
+ mbeanServer);
}
// Constructors --------------------------------------------------
Modified: trunk/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java 2009-09-18 16:59:05 UTC (rev 7972)
+++ trunk/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java 2009-09-19 15:48:25 UTC (rev 7973)
@@ -1316,6 +1316,7 @@
protected QueueControl createManagementControl(SimpleString address, SimpleString queue) throws Exception
{
QueueControl queueControl = createQueueControl(address, queue, mbeanServer);
+
return queueControl;
}
Modified: trunk/tests/src/org/hornetq/tests/integration/management/QueueControlUsingCoreTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/management/QueueControlUsingCoreTest.java 2009-09-18 16:59:05 UTC (rev 7972)
+++ trunk/tests/src/org/hornetq/tests/integration/management/QueueControlUsingCoreTest.java 2009-09-19 15:48:25 UTC (rev 7973)
@@ -259,7 +259,7 @@
public void resume() throws Exception
{
- proxy.invokeOperation("pause");
+ proxy.invokeOperation("resume");
}
public boolean isPaused() throws Exception
More information about the hornetq-commits
mailing list