[hornetq-commits] JBoss hornetq SVN: r8073 - in trunk: src/main/org/hornetq/jms/server/management/impl and 1 other directories.

Author: plugtree Date: 2009-10-08 20:45:01 -0400 (Thu, 08 Oct 2009) New Revision: 8073 Modified: trunk/src/main/org/hornetq/jms/server/management/JMSQueueControl.java trunk/src/main/org/hornetq/jms/server/management/impl/JMSQueueControlImpl.java trunk/tests/src/org/hornetq/tests/integration/jms/server/management/JMSQueueControlTest.java trunk/tests/src/org/hornetq/tests/integration/jms/server/management/JMSQueueControlUsingJMSTest.java Log: Added queue pause and resume to JMSQueueControl. For more info see https://jira.jboss.org/jira/browse/HORNETQ-82 Modified: trunk/src/main/org/hornetq/jms/server/management/JMSQueueControl.java =================================================================== --- trunk/src/main/org/hornetq/jms/server/management/JMSQueueControl.java 2009-10-09 00:43:49 UTC (rev 8072) +++ trunk/src/main/org/hornetq/jms/server/management/JMSQueueControl.java 2009-10-09 00:45:01 UTC (rev 8073) @@ -105,4 +105,14 @@ @Operation(desc = "List the message counters history as HTML", impact = INFO) String listMessageCounterHistoryAsHTML() throws Exception; + @Operation(desc = "Pauses the queue.", impact = INFO) + void pause() throws Exception; + + @Operation(desc = "Returns true if the queue is paused.", impact = INFO) + boolean isPaused() throws Exception; + + @Operation(desc = "Resumes the queue.", impact = INFO) + void resume() throws Exception; + + } Modified: trunk/src/main/org/hornetq/jms/server/management/impl/JMSQueueControlImpl.java =================================================================== --- trunk/src/main/org/hornetq/jms/server/management/impl/JMSQueueControlImpl.java 2009-10-09 00:43:49 UTC (rev 8072) +++ trunk/src/main/org/hornetq/jms/server/management/impl/JMSQueueControlImpl.java 2009-10-09 00:45:01 UTC (rev 8073) @@ -305,6 +305,21 @@ return MessageCounterHelper.listMessageCounterHistoryAsHTML(new MessageCounter[] { counter }); } + public boolean isPaused() throws Exception + { + return coreQueueControl.isPaused(); + } + + public void pause() throws Exception + { + coreQueueControl.pause(); + } + + public void resume() throws Exception + { + coreQueueControl.resume(); + } + // Package protected --------------------------------------------- // Protected ----------------------------------------------------- Modified: trunk/tests/src/org/hornetq/tests/integration/jms/server/management/JMSQueueControlTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/integration/jms/server/management/JMSQueueControlTest.java 2009-10-09 00:43:49 UTC (rev 8072) +++ trunk/tests/src/org/hornetq/tests/integration/jms/server/management/JMSQueueControlTest.java 2009-10-09 00:45:01 UTC (rev 8073) @@ -13,6 +13,7 @@ package org.hornetq.tests.integration.jms.server.management; +import static org.hornetq.tests.integration.management.ManagementControlHelper.createHornetQServerControl; import static org.hornetq.tests.integration.management.ManagementControlHelper.createJMSQueueControl; import static org.hornetq.tests.util.RandomUtil.randomLong; import static org.hornetq.tests.util.RandomUtil.randomSimpleString; @@ -33,6 +34,8 @@ import org.hornetq.core.config.Configuration; import org.hornetq.core.config.TransportConfiguration; import org.hornetq.core.config.impl.ConfigurationImpl; +import org.hornetq.core.management.HornetQServerControl; +import org.hornetq.core.management.QueueControl; import org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory; import org.hornetq.core.remoting.impl.invm.InVMConnectorFactory; import org.hornetq.core.server.HornetQ; @@ -705,7 +708,29 @@ JMSUtil.consumeMessages(1, queue); } + + public void testPauseAndResume() + { + + try + { + JMSQueueControl queueControl = createManagementControl(); + + assertFalse(queueControl.isPaused()); + queueControl.pause(); + assertTrue(queueControl.isPaused()); + queueControl.resume(); + assertFalse(queueControl.isPaused()); + } + catch (Exception e) + { + // TODO Auto-generated catch block + e.printStackTrace(); + } + } + + // Package protected --------------------------------------------- // Protected ----------------------------------------------------- Modified: trunk/tests/src/org/hornetq/tests/integration/jms/server/management/JMSQueueControlUsingJMSTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/integration/jms/server/management/JMSQueueControlUsingJMSTest.java 2009-10-09 00:43:49 UTC (rev 8072) +++ trunk/tests/src/org/hornetq/tests/integration/jms/server/management/JMSQueueControlUsingJMSTest.java 2009-10-09 00:45:01 UTC (rev 8073) @@ -236,6 +236,21 @@ { return (String)proxy.retrieveAttributeValue("JNDIBinding"); } + + public boolean isPaused() throws Exception + { + return (Boolean)proxy.invokeOperation("isPaused"); + } + + public void pause() throws Exception + { + proxy.invokeOperation("pause"); + } + + public void resume() throws Exception + { + proxy.invokeOperation("resume"); + } }; }