[jboss-cvs] JBossAS SVN: r103050 - in trunk/hornetq-int/src/main/java/org/jboss/as/integration/hornetq: management/jms and 1 other directory.

[jboss-cvs-commits at lists.jboss.org]

Author: jmesnil
Date: 2010-03-26 11:09:42 -0400 (Fri, 26 Mar 2010)
New Revision: 103050

Modified:
   trunk/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/jopr/JMSQueueComponent.java
   trunk/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/management/jms/QueueManageMO.java
Log:
HornetQ integration

* map queue availibility in admin console to its paused attribute

Modified: trunk/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/jopr/JMSQueueComponent.java
===================================================================
--- trunk/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/jopr/JMSQueueComponent.java	2010-03-26 15:03:06 UTC (rev 103049)
+++ trunk/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/jopr/JMSQueueComponent.java	2010-03-26 15:09:42 UTC (rev 103050)
@@ -61,7 +61,18 @@
 
    public AvailabilityType getAvailability()
    {
-      return AvailabilityType.UP;
+      try
+      {
+         ManagementView view = getProfileService();
+         ManagedOperation operation = ManagementSupport.getOperation(view, getComponentName(), "isPaused", getComponentType());
+         SimpleValueSupport val = (SimpleValueSupport) operation.invoke(new SimpleValueSupport(SimpleMetaType.STRING, resourceContext.getResourceKey()));
+         boolean paused = ((Boolean)val.getValue()).booleanValue();
+         return paused ? AvailabilityType.DOWN : AvailabilityType.UP;
+      }
+      catch (Exception e)
+      {
+         return AvailabilityType.DOWN;
+      }
    }
 
    @Override

Modified: trunk/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/management/jms/QueueManageMO.java
===================================================================
--- trunk/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/management/jms/QueueManageMO.java	2010-03-26 15:03:06 UTC (rev 103049)
+++ trunk/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/management/jms/QueueManageMO.java	2010-03-26 15:09:42 UTC (rev 103050)
@@ -220,4 +220,14 @@
    {
       return jmsServerControl.getQueueNames();
    }
+   
+   @ManagementOperation(name = "isPaused", description = "is the queue paused?",
+	       params = {
+           @ManagementParameter(name = "name", description = "the queue name"),
+   })
+   public boolean isPaused(String name) throws Exception
+   {
+	   JMSQueueControl control = (JMSQueueControl) managementService.getResource(name);
+	   return control.isPaused();
+   }
 }