[jboss-cvs] JBoss Messaging SVN: r1947 - trunk/tests/src/org/jboss/test/messaging/jms/clustering.

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

Author: ovidiu.feodorov at jboss.com
Date: 2007-01-10 12:13:02 -0500 (Wed, 10 Jan 2007)
New Revision: 1947

Modified:
   trunk/tests/src/org/jboss/test/messaging/jms/clustering/DistributedQueueTest.java
Log:
http://jira.jboss.org/jira/browse/JBMESSAGING-688.
Test passes.


Modified: trunk/tests/src/org/jboss/test/messaging/jms/clustering/DistributedQueueTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/clustering/DistributedQueueTest.java	2007-01-10 17:00:05 UTC (rev 1946)
+++ trunk/tests/src/org/jboss/test/messaging/jms/clustering/DistributedQueueTest.java	2007-01-10 17:13:02 UTC (rev 1947)
@@ -56,10 +56,14 @@
       // start servers with redistribution policies that actually do something
       ServiceAttributeOverrides attrOverrides = new ServiceAttributeOverrides();
 
+      ObjectName postOfficeObjectName = new ObjectName("jboss.messaging:service=PostOffice");
+
       attrOverrides.
-         put(new ObjectName("jboss.messaging:service=PostOffice"), "MessagePullPolicy",
+         put(postOfficeObjectName, "MessagePullPolicy",
              "org.jboss.messaging.core.plugin.postoffice.cluster.DefaultMessagePullPolicy");
 
+      attrOverrides.put(postOfficeObjectName, "StatsSendPeriod", new Long(1000));
+
       ServerManagement.start(0, "all", attrOverrides, true);
       ServerManagement.start(1, "all", attrOverrides, false);
 
@@ -81,6 +85,10 @@
 
          conn = cf.createConnection();
 
+         // make sure we're connecting to node 1
+
+         assertEquals(0, ((JBossConnection)conn).getServerID());
+
          // send a message
 
          Session s = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
@@ -96,18 +104,15 @@
 
          // make sure we're connecting to node 1
 
-         int nodeID = ((ConnectionState)((DelegateSupport)((JBossConnection)conn).
-            getDelegate()).getState()).getServerID();
+         assertEquals(1, ((JBossConnection)conn).getServerID());
 
-         assertEquals(1, nodeID);
-
          s = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
          MessageConsumer c = s.createConsumer(queue1);
          conn.start();
 
          // we must receive the message
 
-         TextMessage tm = (TextMessage)c.receive(1000);
+         TextMessage tm = (TextMessage)c.receive(10000);
          assertNotNull(tm);
          assertEquals("blip", tm.getText());