diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-04-12 14:55:46 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-04-12 14:55:46 +0100 |
| commit | b38e753545e97e96d6629db975d7acbc8cf6fedd (patch) | |
| tree | a930fb65aa210799c557d0e2a1d83fc63c7664e2 /src | |
| parent | 450052add389a8ab31d5bc389c02894bf87a2f79 (diff) | |
| download | rabbitmq-server-git-b38e753545e97e96d6629db975d7acbc8cf6fedd.tar.gz | |
oops
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 404cca2c1f..4b095209da 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -620,7 +620,7 @@ confirm_sender_death(Pid) -> fun (?MODULE, State = #state { known_senders = KS, gm = GM }) -> %% We're running still as a slave - ok = case pmon:is_monitored(KS) of + ok = case pmon:is_monitored(Pid, KS) of false -> ok; true -> gm:broadcast(GM, {ensure_monitoring, [Pid]}), confirm_sender_death(Pid) |