diff options
| author | Luke Bakken <lbakken@pivotal.io> | 2017-06-23 10:41:33 -0700 |
|---|---|---|
| committer | Luke Bakken <luke@bakken.io> | 2017-06-28 08:19:45 -0700 |
| commit | e092c285e753de60ae91f3e5a61268b9988bfb18 (patch) | |
| tree | 1858ec35594ba56921dd2cc24addf26a719aba8f /test | |
| parent | 20e0080aa3f1f4c3ee86054bfb71f4aacb9af714 (diff) | |
| download | rabbitmq-server-git-e092c285e753de60ae91f3e5a61268b9988bfb18.tar.gz | |
Fixes setting ha policy
Diffstat (limited to 'test')
| -rw-r--r-- | test/rabbit_core_metrics_gc_SUITE.erl | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/test/rabbit_core_metrics_gc_SUITE.erl b/test/rabbit_core_metrics_gc_SUITE.erl index 79a40371ee..c76e4de26d 100644 --- a/test/rabbit_core_metrics_gc_SUITE.erl +++ b/test/rabbit_core_metrics_gc_SUITE.erl @@ -341,8 +341,8 @@ x(Name) -> cluster_queue_metrics(Config) -> QueueName = <<"cluster_queue_metrics">>, - A = rabbit_ct_broker_helpers:get_node_config(Config, 0, nodename), - Ch = rabbit_ct_client_helpers:open_channel(Config, A), + Node0 = rabbit_ct_broker_helpers:get_node_config(Config, 0, nodename), + Ch = rabbit_ct_client_helpers:open_channel(Config, Node0), amqp_channel:call(Ch, #'queue.declare'{queue = QueueName}), amqp_channel:call(Ch, #'basic.publish'{routing_key = QueueName}, @@ -355,11 +355,9 @@ cluster_queue_metrics(Config) -> % Synchronize % Check ETS table for data % ets:tab2list(queue_coarse_metrics). - NodeConfig = rabbit_ct_broker_helpers:get_node_config(Config, 0), - NodeName = ?config(nodename, NodeConfig), - Params = [NodeName], - Definition = [{<<"ha-mode">>, <<"nodes">>}, {<<"ha-params">>, Params}], - set_policy(Config, 0, <<"ha-policy-1">>, <<".*">>, queues, Definition), + Node0Name = rabbit_data_coercion:to_binary(Node0), + Definition = [{<<"ha-mode">>, <<"nodes">>}, {<<"ha-params">>, [Node0Name]}], + rabbit_ct_broker_helpers:set_policy(Config, 0, <<"ha-policy-1">>, <<".*">>, <<"queues">>, Definition), amqp_channel:call(Ch, #'queue.delete'{queue=QueueName}), rabbit_ct_client_helpers:close_channel(Ch), |