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 | e8a6c28599527aa212500bac71f2a856f3f3f57e (patch) | |
| tree | a930fb65aa210799c557d0e2a1d83fc63c7664e2 | |
| parent | 96444ccec00a7cc8f5fa4d81cddfc873b17c67b7 (diff) | |
| download | rabbitmq-server-e8a6c28599527aa212500bac71f2a856f3f3f57e.tar.gz | |
oops
| -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 404cca2c..4b095209 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) |