summaryrefslogtreecommitdiff
path: root/src/rabbit_mirror_queue_coordinator.erl
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2013-12-10 12:42:03 +0000
committerSimon MacMullen <simon@rabbitmq.com>2013-12-10 12:42:03 +0000
commitd7b708c3a096bd3f355dee03af4d064f8aec4c47 (patch)
tree71cc8f5a140b28993990b25069767e550324d461 /src/rabbit_mirror_queue_coordinator.erl
parenta3a42f14505cb1e366a931a74ae21a29a6aee444 (diff)
downloadrabbitmq-server-d7b708c3a096bd3f355dee03af4d064f8aec4c47.tar.gz
Add queue_coordinator / queue_syncer / gm. Shift to getting gen_server2 to store the name in most cases.
Diffstat (limited to 'src/rabbit_mirror_queue_coordinator.erl')
-rw-r--r--src/rabbit_mirror_queue_coordinator.erl3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_coordinator.erl b/src/rabbit_mirror_queue_coordinator.erl
index a0e8bcc6..0a034b6d 100644
--- a/src/rabbit_mirror_queue_coordinator.erl
+++ b/src/rabbit_mirror_queue_coordinator.erl
@@ -310,7 +310,8 @@
%%----------------------------------------------------------------------------
start_link(Queue, GM, DeathFun, DepthFun) ->
- gen_server2:start_link(?MODULE, [Queue, GM, DeathFun, DepthFun], []).
+ gen_server2:start_link(?MODULE, [Queue, GM, DeathFun, DepthFun],
+ [{proc_name, Queue#amqqueue.name}]).
get_gm(CPid) ->
gen_server2:call(CPid, get_gm, infinity).