commit dcffe40f54366cb585344d0ec2d57e9dde6d62c8
author rgodfrey <rgodfrey@apache.org> Mon May 27 11:50:30 2019 +0200
committer rgodfrey <rgodfrey@apache.org> Mon May 27 11:50:30 2019 +0200
tree 2e4ef3d16c12851243dd957d07a1e1022f066c8a
parent 9ded8dbcc69cd3ae07d095c05ad29ee6db3dfbd5

QPID-8318 : Fix system test

systests/protocol-tests-amqp-0-8/src/test/java/org/apache/qpid/tests/protocol/v0_8/QueueTest.java

diff --git a/systests/protocol-tests-amqp-0-8/src/test/java/org/apache/qpid/tests/protocol/v0_8/QueueTest.java b/systests/protocol-tests-amqp-0-8/src/test/java/org/apache/qpid/tests/protocol/v0_8/QueueTest.java
index 54a8f20..a5b5c26 100644
--- a/systests/protocol-tests-amqp-0-8/src/test/java/org/apache/qpid/tests/protocol/v0_8/QueueTest.java
+++ b/systests/protocol-tests-amqp-0-8/src/test/java/org/apache/qpid/tests/protocol/v0_8/QueueTest.java
@@ -430,15 +430,14 @@
                                                    .queue().purgeName(BrokerAdmin.TEST_QUEUE_NAME).purge()
                                                    .consumeResponse().getLatestResponse(QueuePurgeOkBody.class);
 
-            /* TODO purge currently always returns 0 */
-            //assertThat(response.getMessageCount(), is(equalTo(1L)));
+            assertThat(response.getMessageCount(), is(equalTo(1L)));
 
             QueueDeclareOkBody passive = interaction.queue()
                                                     .declareName(BrokerAdmin.TEST_QUEUE_NAME)
                                                     .declarePassive(true).declare()
                                                     .consumeResponse().getLatestResponse(QueueDeclareOkBody.class);
             assertThat(passive.getQueue(), is(equalTo(AMQShortString.valueOf(BrokerAdmin.TEST_QUEUE_NAME))));
-            assertThat(response.getMessageCount(), is(equalTo(0L)));
+            assertThat(passive.getMessageCount(), is(equalTo(0L)));
         }
     }