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 | 9207ac7614247cc09b9d6785307c9ead042fb3bc (patch) | |
| tree | 4d2273d952912043727f03e6fc4b47627e076c02 | |
| parent | 55a89d13cb3f6d7d7cfe2abe8737c8b0296eed1e (diff) | |
| download | rabbitmq-server-9207ac7614247cc09b9d6785307c9ead042fb3bc.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 7e857fc7..adab5d03 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, |