[hornetq-commits] JBoss hornetq SVN: r12161 - trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/client.
do-not-reply at jboss.org
do-not-reply at jboss.org
Wed Feb 22 09:29:11 EST 2012
Author: gaohoward
Date: 2012-02-22 09:29:10 -0500 (Wed, 22 Feb 2012)
New Revision: 12161
Modified:
trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/client/RedeliveryConsumerTest.java
Log:
fix test failure
Modified: trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/client/RedeliveryConsumerTest.java
===================================================================
--- trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/client/RedeliveryConsumerTest.java 2012-02-21 22:59:13 UTC (rev 12160)
+++ trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/client/RedeliveryConsumerTest.java 2012-02-22 14:29:10 UTC (rev 12161)
@@ -209,7 +209,7 @@
session.stop();
// if strictUpdate == true, this will simulate a crash, where the server is stopped without closing/rolling back
- // the session
+ // the session, but the delivery count still persisted, so the final delivery count is 2 too.
if (!strictUpdate)
{
// If non Strict, at least rollback/cancel should still update the delivery-counts
@@ -233,7 +233,7 @@
consumer = session.createConsumer(ADDRESS);
msg = consumer.receive(1000);
Assert.assertNotNull(msg);
- Assert.assertEquals(strictUpdate ? 1 : 2, msg.getDeliveryCount());
+ Assert.assertEquals(strictUpdate ? 2 : 2, msg.getDeliveryCount());
session.close();
}
More information about the hornetq-commits
mailing list