diff options
| author | D Corbacho <diana@rabbitmq.com> | 2018-12-24 15:24:42 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-12-24 15:24:42 +0100 |
| commit | 655934d4ad9df0808c218571bb823904413faf48 (patch) | |
| tree | fb4880ae7e161ca8840b24f76825a9952b2f039e /test | |
| parent | 7e347885de96e95ce85fab577861b98aa0fa7dbf (diff) | |
| parent | 16728ecbc56c4a200a4d86ff99f4527b2e8dbec7 (diff) | |
| download | rabbitmq-server-git-655934d4ad9df0808c218571bb823904413faf48.tar.gz | |
Merge pull request #1809 from rabbitmq/qq-purge-bug-fix
Quorum queue: purge should not remove checkout out messages.
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) -> |