diff options
| author | Michael Klishin <michael@novemberain.com> | 2017-04-06 06:54:13 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-04-06 06:54:13 +0300 |
| commit | 0b0308829c716d3226c4d71efefe4d0b5f57473c (patch) | |
| tree | 5105b06b91fa90c9a825113a3f107b6ba8f7c601 /src | |
| parent | fe56987d5b8ccf6b8ad073f240c9bf8a330e532d (diff) | |
| parent | 432f46df0f19322318b686446181f3d44d3998d6 (diff) | |
| download | rabbitmq-server-git-0b0308829c716d3226c4d71efefe4d0b5f57473c.tar.gz | |
Merge pull request #1176 from rabbitmq/rabbitmq-server-1172
Make queue master locator treat queue args as AMQP table.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_master_location_misc.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_queue_master_location_misc.erl b/src/rabbit_queue_master_location_misc.erl index 2cc6d515f4..0b9efdd6fc 100644 --- a/src/rabbit_queue_master_location_misc.erl +++ b/src/rabbit_queue_master_location_misc.erl @@ -63,8 +63,8 @@ get_location(Queue=#amqqueue{})-> end. get_location_mod_by_args(#amqqueue{arguments=Args}) -> - case proplists:lookup(<<"x-queue-master-locator">> , Args) of - {<<"x-queue-master-locator">> , Strategy} -> + case rabbit_misc:table_lookup(Args, <<"x-queue-master-locator">>) of + {_Type, Strategy} -> case rabbit_queue_location_validator:validate_strategy(Strategy) of Reply = {ok, _CB} -> Reply; Error -> Error |