diff options
| author | D Corbacho <diana@rabbitmq.com> | 2018-12-14 10:01:59 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-12-14 10:01:59 +0000 |
| commit | b914cdb7f539343d13eef4522608559d69edd828 (patch) | |
| tree | 1bbe134a16be66db16709bb8bbb46d232749c3a2 /test | |
| parent | df52e8d607740a1e47754b1300c2d8403898e451 (diff) | |
| parent | 0a21df17d97ead045bedd42bf2fd867687eeec17 (diff) | |
| download | rabbitmq-server-git-b914cdb7f539343d13eef4522608559d69edd828.tar.gz | |
Merge pull request #1800 from rabbitmq/qq-ghost-consumer-fix
Ensure quorum queue consumers are cleaned up
Diffstat (limited to 'test')
| -rw-r--r-- | test/quorum_queue_SUITE.erl | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/test/quorum_queue_SUITE.erl b/test/quorum_queue_SUITE.erl index 5b87c5be20..523506b0e0 100644 --- a/test/quorum_queue_SUITE.erl +++ b/test/quorum_queue_SUITE.erl @@ -1507,7 +1507,10 @@ basic_cancel(Config) -> wait_for_messages_pending_ack(Servers, RaName, 1), amqp_channel:call(Ch, #'basic.cancel'{consumer_tag = <<"ctag">>}), wait_for_messages_ready(Servers, RaName, 1), - wait_for_messages_pending_ack(Servers, RaName, 0) + wait_for_messages_pending_ack(Servers, RaName, 0), + [] = rpc:call(Server, ets, tab2list, [consumer_created]) + after 5000 -> + exit(basic_deliver_timeout) end. purge(Config) -> |