diff options
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 4190903409..3464494cef 100644 --- a/test/quorum_queue_SUITE.erl +++ b/test/quorum_queue_SUITE.erl @@ -1503,7 +1503,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) -> |