[jboss-cvs] JBossAS SVN: r86931 - branches/Branch_5_x/testsuite/src/main/org/jboss/test/profileservice/test.

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

Author: emuckenhuber
Date: 2009-04-07 11:42:20 -0400 (Tue, 07 Apr 2009)
New Revision: 86931

Modified:
   branches/Branch_5_x/testsuite/src/main/org/jboss/test/profileservice/test/JmsDestinationUnitTestCase.java
Log:
[JBAS-6720] test topic metrics.

Modified: branches/Branch_5_x/testsuite/src/main/org/jboss/test/profileservice/test/JmsDestinationUnitTestCase.java
===================================================================
--- branches/Branch_5_x/testsuite/src/main/org/jboss/test/profileservice/test/JmsDestinationUnitTestCase.java	2009-04-07 15:39:24 UTC (rev 86930)
+++ branches/Branch_5_x/testsuite/src/main/org/jboss/test/profileservice/test/JmsDestinationUnitTestCase.java	2009-04-07 15:42:20 UTC (rev 86931)
@@ -33,7 +33,10 @@
 import javax.jms.QueueSession;
 import javax.jms.Session;
 import javax.jms.Topic;
+import javax.jms.TopicConnection;
 import javax.jms.TopicConnectionFactory;
+import javax.jms.TopicPublisher;
+import javax.jms.TopicSession;
 
 import junit.framework.Test;
 import junit.framework.TestSuite;
@@ -48,6 +51,7 @@
 import org.jboss.metatype.api.types.MapCompositeMetaType;
 import org.jboss.metatype.api.types.MetaType;
 import org.jboss.metatype.api.types.SimpleMetaType;
+import org.jboss.metatype.api.values.CollectionValue;
 import org.jboss.metatype.api.values.CompositeValue;
 import org.jboss.metatype.api.values.CompositeValueSupport;
 import org.jboss.metatype.api.values.MapCompositeValueSupport;
@@ -95,18 +99,19 @@
    {
       TestSuite suite = new TestSuite();
 
-      suite.addTest(new JmsDestinationUnitTestCase("testQueueTemplate"));
-      suite.addTest(new JmsDestinationUnitTestCase("testTopicTemplate"));
-      suite.addTest(new JmsDestinationUnitTestCase("testDLQ"));
-      suite.addTest(new JmsDestinationUnitTestCase("testCreateQueue"));
-      suite.addTest(new JmsDestinationUnitTestCase("testQueueMetrics"));
-      suite.addTest(new JmsDestinationUnitTestCase("testQueueOperations"));
-      suite.addTest(new JmsDestinationUnitTestCase("testRemoveQueue"));
+//      suite.addTest(new JmsDestinationUnitTestCase("testQueueTemplate"));
+//      suite.addTest(new JmsDestinationUnitTestCase("testTopicTemplate"));
+//      suite.addTest(new JmsDestinationUnitTestCase("testDLQ"));
+//      suite.addTest(new JmsDestinationUnitTestCase("testCreateQueue"));
+//      suite.addTest(new JmsDestinationUnitTestCase("testQueueMetrics"));
+//      suite.addTest(new JmsDestinationUnitTestCase("testQueueOperations"));
+//      suite.addTest(new JmsDestinationUnitTestCase("testRemoveQueue"));
       suite.addTest(new JmsDestinationUnitTestCase("testCreateTopic"));
+      suite.addTest(new JmsDestinationUnitTestCase("testTopicMetrics"));
       suite.addTest(new JmsDestinationUnitTestCase("testTopicOperations"));
       suite.addTest(new JmsDestinationUnitTestCase("testRemoveTopic"));
-      suite.addTest(new JmsDestinationUnitTestCase("testCreateSecureQueue"));
-      suite.addTest(new JmsDestinationUnitTestCase("testRemoveSecureQueue"));
+//      suite.addTest(new JmsDestinationUnitTestCase("testCreateSecureQueue"));
+//      suite.addTest(new JmsDestinationUnitTestCase("testRemoveSecureQueue"));
 
       return suite;
    }  
@@ -300,6 +305,46 @@
       assertEquals("testCreateTopic", topic.getName());
    }
    
+
+   public void testTopicMetrics() throws Exception
+   {
+      ManagementView mgtView = getManagementView();
+      ManagedComponent component = mgtView.getComponent("testCreateTopic", TopicType);
+      assertNotNull(component);
+      
+      Topic topic = (Topic) getInitialContext().lookup("testCreateTopic");
+      TopicConnectionFactory cf = (TopicConnectionFactory) getInitialContext().lookup("ConnectionFactory");
+      
+      TopicConnection connection = cf.createTopicConnection();
+      TopicSession session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
+      session.createSubscriber(topic);
+      
+      TopicPublisher pub = session.createPublisher(topic);
+      
+      for(int i = 0; i < 10; i++)
+         pub.send(session.createTextMessage("Message nr " + i));
+      
+      SimpleValue nondurable = (SimpleValue)component.getProperty("nonDurableSubscriptionsCount").getValue();
+      SimpleValue durable = (SimpleValue)component.getProperty("durableSubscriptionsCount").getValue();
+      SimpleValue all = (SimpleValue)component.getProperty("allSubscriptionsCount").getValue();
+      SimpleValue allMessageCount = (SimpleValue)component.getProperty("allMessageCount").getValue();
+      
+      CollectionValue messageCounters = (CollectionValue) component.getProperty("messageCounters").getValue();
+      assertNotNull(messageCounters);
+      
+      assertEquals(1, nondurable.getValue());
+      assertEquals(0, durable.getValue());
+      assertEquals(1, all.getValue());
+      assertEquals(10, allMessageCount.getValue());
+
+      CompositeValue messageCounter = (CompositeValue) messageCounters.iterator().next();
+      assertNotNull(messageCounter);
+      
+      SimpleValue count = (SimpleValue) messageCounter.get("messageCount");
+      assertEquals(count, allMessageCount);
+      
+   }
+
    public void testTopicOperations() throws Exception
    {
       ManagedComponent component = getManagementView().getComponent("testCreateTopic", TopicType);