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

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(); }