diff options
| author | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2015-07-15 11:03:38 +0100 |
|---|---|---|
| committer | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2015-07-15 11:03:38 +0100 |
| commit | 40b291242fb6aa1d4b11a08b1d5e28581a8ab3cc (patch) | |
| tree | 305282514f20601ef2e686d353c31ab6866a195b | |
| parent | 2cd399a88f70c840e8616f1857797ee525e55e52 (diff) | |
| download | rabbitmq-server-git-40b291242fb6aa1d4b11a08b1d5e28581a8ab3cc.tar.gz | |
Takes queue name from #binding.destination
References #121
| -rw-r--r-- | src/rabbit_queue_location_min_masters.erl | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/rabbit_queue_location_min_masters.erl b/src/rabbit_queue_location_min_masters.erl index 98a61284e6..ee7a1339b1 100644 --- a/src/rabbit_queue_location_min_masters.erl +++ b/src/rabbit_queue_location_min_masters.erl @@ -62,8 +62,11 @@ get_bound_queue_masters_per_vhost([VHost|RemVHosts], Acc) -> get_queue_master_per_binding(_VHost, [], BoundQueueNodes) -> BoundQueueNodes; -get_queue_master_per_binding(VHost, [#binding{key=QueueName}|RemBindings], - QueueMastersAcc) -> +get_queue_master_per_binding(VHost, [#binding{destination= + #resource{kind=queue, + name=QueueName}}| + RemBindings], + QueueMastersAcc) -> QueueMastersAcc0 = case rabbit_queue_master_location_misc:lookup_master( QueueName, VHost) of {ok, Master} when is_atom(Master) -> |