diff options
| author | Daniil Fedotov <hairyhum@gmail.com> | 2018-04-18 17:38:21 +0100 |
|---|---|---|
| committer | Daniil Fedotov <hairyhum@gmail.com> | 2018-04-18 17:38:21 +0100 |
| commit | 0c6a4dc64b61f40d0cb50bfa0dd32b41e783a4fe (patch) | |
| tree | ec3be4e58d03bfca00108ea4f1725616946040e7 /test | |
| parent | 5f06ff470fcd4e395f4c66da4376f1f660172451 (diff) | |
| download | rabbitmq-server-git-0c6a4dc64b61f40d0cb50bfa0dd32b41e783a4fe.tar.gz | |
Test for ha-promote-on-failure policy key
Diffstat (limited to 'test')
| -rw-r--r-- | test/dynamic_ha_SUITE.erl | 35 |
1 files changed, 35 insertions, 0 deletions
diff --git a/test/dynamic_ha_SUITE.erl b/test/dynamic_ha_SUITE.erl index 7629d2264a..7335442f5a 100644 --- a/test/dynamic_ha_SUITE.erl +++ b/test/dynamic_ha_SUITE.erl @@ -59,6 +59,7 @@ groups() -> vhost_deletion, force_delete_if_no_master, promote_on_shutdown, + promote_on_failure, slave_recovers_after_vhost_failure, slave_recovers_after_vhost_down_an_up, master_migrates_on_vhost_down, @@ -287,6 +288,40 @@ force_delete_if_no_master(Config) -> amqp_channel:call(BCh3, #'queue.delete'{queue = <<"ha.nopromote.test2">>}), ok. +promote_on_failure(Config) -> + [A, B] = rabbit_ct_broker_helpers:get_node_configs(Config, nodename), + rabbit_ct_broker_helpers:set_ha_policy(Config, A, <<"^ha.promote">>, + <<"all">>, [{<<"ha-promote-on-failure">>, <<"always">>}]), + rabbit_ct_broker_helpers:set_ha_policy(Config, A, <<"^ha.nopromote">>, + <<"all">>, [{<<"ha-promote-on-failure">>, <<"when-synced">>}]), + + ACh = rabbit_ct_client_helpers:open_channel(Config, A), + [begin + amqp_channel:call(ACh, #'queue.declare'{queue = Q, + durable = true}), + rabbit_ct_client_helpers:publish(ACh, Q, 10) + end || Q <- [<<"ha.promote.test">>, <<"ha.nopromote.test">>]], + ok = rabbit_ct_broker_helpers:restart_node(Config, B), + ok = rabbit_ct_broker_helpers:kill_node(Config, A), + BCh = rabbit_ct_client_helpers:open_channel(Config, B), + #'queue.declare_ok'{message_count = 0} = + amqp_channel:call( + BCh, #'queue.declare'{queue = <<"ha.promote.test">>, + durable = true}), + ?assertExit( + {{shutdown, {server_initiated_close, 404, _}}, _}, + amqp_channel:call( + BCh, #'queue.declare'{queue = <<"ha.nopromote.test">>, + durable = true})), + ok = rabbit_ct_broker_helpers:start_node(Config, A), + ACh2 = rabbit_ct_client_helpers:open_channel(Config, A), + #'queue.declare_ok'{message_count = 10} = + amqp_channel:call( + ACh2, #'queue.declare'{queue = <<"ha.nopromote.test">>, + durable = true}), + ok. + + promote_on_shutdown(Config) -> [A, B] = rabbit_ct_broker_helpers:get_node_configs(Config, nodename), rabbit_ct_broker_helpers:set_ha_policy(Config, A, <<"^ha.promote">>, |