diff options
| -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], |