diff options
author | Simon MacMullen <simon@rabbitmq.com> | 2013-12-10 12:42:03 +0000 |
---|---|---|
committer | Simon MacMullen <simon@rabbitmq.com> | 2013-12-10 12:42:03 +0000 |
commit | d7b708c3a096bd3f355dee03af4d064f8aec4c47 (patch) | |
tree | 71cc8f5a140b28993990b25069767e550324d461 /src/rabbit_mirror_queue_coordinator.erl | |
parent | a3a42f14505cb1e366a931a74ae21a29a6aee444 (diff) | |
download | rabbitmq-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.erl | 3 |
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). |