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

[do-not-reply at jboss.org]

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");
+         }
       };
    }