diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-10-03 12:54:38 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-10-03 12:54:38 +0100 |
| commit | cd4bfd94ff3b1023fc6adada6c14ec274f1f34a3 (patch) | |
| tree | 4d2273d952912043727f03e6fc4b47627e076c02 | |
| parent | 604ddf89db268300ec82597436403c5a77cdf6ba (diff) | |
| download | rabbitmq-server-git-cd4bfd94ff3b1023fc6adada6c14ec274f1f34a3.tar.gz | |
Explain
| -rw-r--r-- | src/rabbit_amqqueue.erl | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 7e857fc7b2..adab5d032c 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -628,6 +628,12 @@ deliver(Qs, Delivery = #delivery{mandatory = false}, Flow) -> flow -> [credit_flow:send(QPid) || QPid <- QPids]; noflow -> ok end, + + %% We let slaves know that they were being addressed as slaves at + %% the time - if they receive such a message from the channel + %% after they have become master they should mark the message as + %% redelivered since they do not know what the master may have + %% done with it. MMsg = {deliver, Delivery, false, Flow}, SMsg = {deliver, Delivery, true, Flow}, delegate:invoke_no_result(MPids, |