diff options
Diffstat (limited to 'qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java')
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java index 5f2935a7e0..576bb3c90c 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java @@ -42,6 +42,7 @@ import org.apache.qpid.AMQException; import org.apache.qpid.client.AMQDestination; import org.apache.qpid.client.AMQQueue; import org.apache.qpid.client.AMQSession; +import org.apache.qpid.client.CustomJMSXProperty; import org.apache.qpid.framing.AMQShortString; import org.apache.qpid.server.queue.AMQQueueFactory; import org.apache.qpid.test.utils.QpidTestCase; @@ -402,6 +403,10 @@ public class MaxDeliveryCountTest extends QpidTestCase } _deliveryAttempts++; //increment count of times the current rolled back/recovered message(s) have been seen + + //verify JMSXDeliveryCount + assertEquals("Value for JMSXDeliveryCount was not as expected", + _deliveryAttempts, message.getIntProperty("JMSXDeliveryCount")); switch(deliveryMode) { @@ -541,6 +546,10 @@ public class MaxDeliveryCountTest extends QpidTestCase _deliveryAttempts++; //increment count of times the current rolled back/recovered message(s) have been seen + //verify JMSXDeliveryCount + assertEquals("Value for JMSXDeliveryCount was not as expected", + _deliveryAttempts, message.getIntProperty("JMSXDeliveryCount")); + switch(deliveryMode) { case Session.SESSION_TRANSACTED: |