diff options
| author | Luke Bakken <lbakken@pivotal.io> | 2017-08-09 06:32:06 -0700 |
|---|---|---|
| committer | Luke Bakken <lbakken@pivotal.io> | 2017-08-09 06:32:06 -0700 |
| commit | 23884dd83be137c356d4ae3ec19c7bc686118573 (patch) | |
| tree | 37a97de9edeaa8c0f3e416aed04e0309631d28f2 /test | |
| parent | 0c30c18031a20eff72fc85bddb41d5545eda925f (diff) | |
| download | rabbitmq-server-git-23884dd83be137c356d4ae3ec19c7bc686118573.tar.gz | |
Begin adding test for #1323
Diffstat (limited to 'test')
| -rw-r--r-- | test/partitions_SUITE.erl | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/test/partitions_SUITE.erl b/test/partitions_SUITE.erl index b09d05b550..b533d8f7b6 100644 --- a/test/partitions_SUITE.erl +++ b/test/partitions_SUITE.erl @@ -43,7 +43,8 @@ groups() -> {net_ticktime_1, [], [ {cluster_size_2, [], [ ctl_ticktime_sync, - prompt_disconnect_detection + prompt_disconnect_detection, + clean_up_exclusive_queues ]}, {cluster_size_3, [], [ autoheal, @@ -282,6 +283,15 @@ prompt_disconnect_detection(Config) -> rabbit_ct_client_helpers:close_channel(ChB), ok. +clean_up_exclusive_queues(Config) -> + rabbit_ct_broker_helpers:set_ha_policy(Config, 0, <<".*">>, <<"all">>), + [A, B] = rabbit_ct_broker_helpers:get_node_configs(Config, nodename), + ChA = rabbit_ct_client_helpers:open_channel(Config, A), + amqp_channel:call(ChA, #'queue.declare'{queue = <<"excl">>, + exclusive = true}), + block_unblock([{A, B}]), + ok. + ctl_ticktime_sync(Config) -> %% Server has 1s net_ticktime, make sure ctl doesn't get disconnected Cmd = ["eval", "timer:sleep(5000)."], |