[hornetq-commits] JBoss hornetq SVN: r9405 - trunk/tests/src/org/hornetq/tests/integration/client.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-07-16 04:13:34 -0400 (Fri, 16 Jul 2010)
New Revision: 9405

Modified:
   trunk/tests/src/org/hornetq/tests/integration/client/PagingTest.java
Log:
fix PagingTest disabled_testDepageDuringTransaction2

* message #0 was sent before the queue was created and would not be consumed

Modified: trunk/tests/src/org/hornetq/tests/integration/client/PagingTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/client/PagingTest.java	2010-07-16 04:47:08 UTC (rev 9404)
+++ trunk/tests/src/org/hornetq/tests/integration/client/PagingTest.java	2010-07-16 08:13:34 UTC (rev 9405)
@@ -400,22 +400,19 @@
          byte[] body = new byte[messageSize];
 
          ClientSession sessionTransacted = sf.createSession(null, null, false, false, false, false, 0);
-
          ClientProducer producerTransacted = sessionTransacted.createProducer(PagingTest.ADDRESS);
-         
+
+         ClientSession session = sf.createSession(null, null, false, true, true, false, 0);
+         session.createQueue(PagingTest.ADDRESS, PagingTest.ADDRESS, null, true);
+
          ClientMessage firstMessage = sessionTransacted.createMessage(IS_DURABLE_MESSAGE);
          firstMessage.getBodyBuffer().writeBytes(body);
          firstMessage.putIntProperty(new SimpleString("id"), 0);
          
          producerTransacted.send(firstMessage);
 
-         ClientSession session = sf.createSession(null, null, false, true, true, false, 0);
-
-         session.createQueue(PagingTest.ADDRESS, PagingTest.ADDRESS, null, true);
-
          ClientProducer producer = session.createProducer(PagingTest.ADDRESS);
 
-
          ClientMessage message = null;
 
          int numberOfMessages = 0;
@@ -482,8 +479,9 @@
 
             Integer messageID = (Integer)message.getObjectProperty(new SimpleString("id"));
 
+//             System.out.println(messageID);
             Assert.assertNotNull(messageID);
-            Assert.assertEquals("message received out of order", messageID.intValue(), i);
+            Assert.assertEquals("message received out of order", i, messageID.intValue());
 
             message.acknowledge();
          }