diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2017-08-10 04:23:12 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2017-08-10 04:23:12 +0300 |
| commit | c8de5f78d736a952b7bd620570a21c95e4277fda (patch) | |
| tree | 1251f02007e4d28df8de69eb324ce5e8630cbf78 | |
| parent | 60cbe625c37f88a0a6592a2cc81b8898e2636e93 (diff) | |
| parent | fd50fd7d260393c7dee795a24b86ff82682aec1f (diff) | |
| download | rabbitmq-server-git-c8de5f78d736a952b7bd620570a21c95e4277fda.tar.gz | |
Merge branch 'stable'
| -rw-r--r-- | test/simple_ha_SUITE.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/test/simple_ha_SUITE.erl b/test/simple_ha_SUITE.erl index 6550ad16c4..a0499b9d59 100644 --- a/test/simple_ha_SUITE.erl +++ b/test/simple_ha_SUITE.erl @@ -121,7 +121,6 @@ declare_synchrony(Config) -> #amqp_msg{props = #'P_basic'{delivery_mode = 2}}), amqp_channel:wait_for_confirms(RabbitCh), rabbit_ct_broker_helpers:kill_node(Config, Rabbit), - timer:sleep(?DELAY), #'queue.declare_ok'{message_count = 1} = declare(HareCh, Q), ok. @@ -139,8 +138,10 @@ clean_up_exclusive_queues(Config) -> amqp_channel:call(ChA, #'queue.declare'{queue = QName, exclusive = true}), ok = rabbit_ct_broker_helpers:kill_node(Config, A), + timer:sleep(?DELAY), [] = rabbit_ct_broker_helpers:rpc(Config, B, rabbit_amqqueue, list, []), ok = rabbit_ct_broker_helpers:start_node(Config, A), + timer:sleep(?DELAY), [[],[]] = rabbit_ct_broker_helpers:rpc_all(Config, rabbit_amqqueue, list, []), ok. |