diff options
| author | kjnilsson <knilsson@pivotal.io> | 2019-10-21 17:58:45 +0100 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2019-10-24 15:46:18 +0100 |
| commit | d161bd694a9cd3d451843fd5a773b03ed17bbff2 (patch) | |
| tree | c58751a949c591f7fd7179bc8b5c47c04c236e5f | |
| parent | 1883667ab4bc574fdf0f65259268ed1738e82759 (diff) | |
| download | rabbitmq-server-git-d161bd694a9cd3d451843fd5a773b03ed17bbff2.tar.gz | |
Also use local option for log effects
| -rw-r--r-- | src/rabbit_fifo.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_fifo.erl b/src/rabbit_fifo.erl index f414d28c04..8977eff74e 100644 --- a/src/rabbit_fifo.erl +++ b/src/rabbit_fifo.erl @@ -1431,8 +1431,9 @@ send_log_effect({CTag, CPid}, IdxMsgs) -> Msgs = lists:zipwith(fun({enqueue, _, _, Msg}, {MsgId, Header}) -> {MsgId, {Header, Msg}} end, Log, Data), - [{send_msg, CPid, {delivery, CTag, Msgs}, ra_event}] - end}. + [{send_msg, CPid, {delivery, CTag, Msgs}, [local, ra_event]}] + end, + {local, node(CPid)}}. reply_log_effect(RaftIdx, MsgId, Header, Ready, From) -> {log, [RaftIdx], |