diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-08-10 15:05:07 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-08-10 15:05:07 +0100 |
| commit | ab82e9f59f7e376f8978864840249051b4bffdab (patch) | |
| tree | ccbeadc9517fe5ee9033d2dc8e13c9f48f139da8 /src | |
| parent | 282c6f53d129fc7b0e1589e84fb41f575df60428 (diff) | |
| download | rabbitmq-server-git-ab82e9f59f7e376f8978864840249051b4bffdab.tar.gz | |
I think we can be more assertful here.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_coordinator.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_coordinator.erl b/src/rabbit_mirror_queue_coordinator.erl index 00ef72ac74..072de5b2f2 100644 --- a/src/rabbit_mirror_queue_coordinator.erl +++ b/src/rabbit_mirror_queue_coordinator.erl @@ -341,8 +341,8 @@ handle_call(get_gm, _From, State = #state { gm = GM }) -> handle_cast({gm_deaths, Deaths}, State = #state { q = #amqqueue { name = QueueName } }) -> case rabbit_mirror_queue_misc:remove_from_queue(QueueName, Deaths) of - {ok, Pid, OldPid, DeadPids} when node(Pid) =:= node() -> - rabbit_mirror_queue_misc:report_deaths(true, QueueName, OldPid, + {ok, Pid, Pid, DeadPids} when node(Pid) =:= node() -> + rabbit_mirror_queue_misc:report_deaths(true, QueueName, Pid, DeadPids), noreply(State); {error, not_found} -> |