diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-08-11 13:36:45 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-08-11 13:36:45 +0100 |
| commit | 2d2ca544a47486fb82aacba442ac8fed57d1e40f (patch) | |
| tree | 4c20c0ab8aff4312f43b2b9c56851028afc8bbc2 /src/rabbit_mirror_queue_coordinator.erl | |
| parent | d55010f9d54b7f8cf338a49f0507809053988d09 (diff) | |
| download | rabbitmq-server-2d2ca544a47486fb82aacba442ac8fed57d1e40f.tar.gz | |
Report queue slave events by name rather than by QPid.
Diffstat (limited to 'src/rabbit_mirror_queue_coordinator.erl')
| -rw-r--r-- | src/rabbit_mirror_queue_coordinator.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_coordinator.erl b/src/rabbit_mirror_queue_coordinator.erl index bae4df47..8ed2bede 100644 --- a/src/rabbit_mirror_queue_coordinator.erl +++ b/src/rabbit_mirror_queue_coordinator.erl @@ -343,7 +343,7 @@ handle_cast({gm_deaths, Deaths}, when node(MPid) =:= node() -> case rabbit_mirror_queue_misc:remove_from_queue(QueueName, Deaths) of {ok, MPid, DeadPids} -> - rabbit_mirror_queue_misc:report_deaths(MPid, true, QueueName, MPid, + rabbit_mirror_queue_misc:report_deaths(MPid, true, QueueName, DeadPids), noreply(State); {error, not_found} -> |