diff options
| author | kjnilsson <knilsson@pivotal.io> | 2018-12-21 15:02:21 +0000 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2018-12-21 15:02:21 +0000 |
| commit | 16728ecbc56c4a200a4d86ff99f4527b2e8dbec7 (patch) | |
| tree | fb4880ae7e161ca8840b24f76825a9952b2f039e /test | |
| parent | 7e347885de96e95ce85fab577861b98aa0fa7dbf (diff) | |
| download | rabbitmq-server-git-16728ecbc56c4a200a4d86ff99f4527b2e8dbec7.tar.gz | |
Quorum queue: purege should not remove checkout out messages.
As these may be returned by a consumer after the purge.
[#162811681]
Diffstat (limited to 'test')
| -rw-r--r-- | test/quorum_queue_SUITE.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/test/quorum_queue_SUITE.erl b/test/quorum_queue_SUITE.erl index 6f06f3b874..ee73d1ed7b 100644 --- a/test/quorum_queue_SUITE.erl +++ b/test/quorum_queue_SUITE.erl @@ -1539,8 +1539,8 @@ purge(Config) -> _DeliveryTag = consume(Ch, QQ, false), wait_for_messages_ready(Servers, RaName, 1), wait_for_messages_pending_ack(Servers, RaName, 1), - {'queue.purge_ok', 2} = amqp_channel:call(Ch, #'queue.purge'{queue = QQ}), - wait_for_messages_pending_ack(Servers, RaName, 0), + {'queue.purge_ok', 1} = amqp_channel:call(Ch, #'queue.purge'{queue = QQ}), + wait_for_messages_pending_ack(Servers, RaName, 1), wait_for_messages_ready(Servers, RaName, 0). sync_queue(Config) -> |