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

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

Author: clebert.suconic at jboss.com
Date: 2007-08-31 10:22:05 -0400 (Fri, 31 Aug 2007)
New Revision: 3081

Modified:
   trunk/tests/src/org/jboss/test/messaging/jms/clustering/DistributedQueueTestBase.java
Log:
http://jira.jboss.org/jira/browse/JBMESSAGING-1063 - test

Modified: trunk/tests/src/org/jboss/test/messaging/jms/clustering/DistributedQueueTestBase.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/clustering/DistributedQueueTestBase.java	2007-08-30 02:23:27 UTC (rev 3080)
+++ trunk/tests/src/org/jboss/test/messaging/jms/clustering/DistributedQueueTestBase.java	2007-08-31 14:22:05 UTC (rev 3081)
@@ -34,6 +34,8 @@
 import javax.jms.TextMessage;
 
 import org.jboss.test.messaging.tools.ServerManagement;
+import org.jboss.jms.message.JBossMessage;
+import org.jboss.jms.message.TextMessageProxy;
 
 
 /**
@@ -537,12 +539,19 @@
          cons1.close();
          
          //Send more messages at node 0
-         
+
+         String messageIdCorrelate[] = new String[NUM_MESSAGES];
+
          for (int i = 0; i < NUM_MESSAGES; i++)
          {
             TextMessage tm = sess0.createTextMessage("message3-" + i);
 
             prod0.send(tm);
+
+            messageIdCorrelate[i] = tm.getJMSMessageID();
+
+            log.info("SetID[" + i + "]=" + tm.getJMSMessageID());
+
          }
               
          // consume them on node2
@@ -550,7 +559,8 @@
          for (int i = 0; i < NUM_MESSAGES; i++)
          {
             TextMessage tm = (TextMessage)cons2.receive(1000);
-                  
+
+            assertEquals(messageIdCorrelate[i], tm.getJMSMessageID());
             assertNotNull(tm);
             
             assertEquals("message3-" + i, tm.getText());