diff options
| author | kjnilsson <knilsson@pivotal.io> | 2019-10-18 14:58:55 +0100 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2019-10-24 15:46:18 +0100 |
| commit | 1883667ab4bc574fdf0f65259268ed1738e82759 (patch) | |
| tree | 406debf160045d92e8065c625be25680b2de0c20 | |
| parent | 2fd609388022681995b9263cbedf5fa58e57c302 (diff) | |
| download | rabbitmq-server-git-1883667ab4bc574fdf0f65259268ed1738e82759.tar.gz | |
Send QQ deliveries as local
So that a follower can deliver them if the consuming channel is local to
them in the cluster.
[#161555213]
| -rw-r--r-- | src/rabbit_fifo.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_fifo.erl b/src/rabbit_fifo.erl index 12083b105c..f414d28c04 100644 --- a/src/rabbit_fifo.erl +++ b/src/rabbit_fifo.erl @@ -1422,7 +1422,7 @@ take_next_msg(#?MODULE{returns = Returns, end. send_msg_effect({CTag, CPid}, Msgs) -> - {send_msg, CPid, {delivery, CTag, Msgs}, ra_event}. + {send_msg, CPid, {delivery, CTag, Msgs}, [local, ra_event]}. send_log_effect({CTag, CPid}, IdxMsgs) -> {RaftIdxs, Data} = lists:unzip(IdxMsgs), |