diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_fifo.erl | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/rabbit_fifo.erl b/src/rabbit_fifo.erl index ccacc136fb..68337adcaa 100644 --- a/src/rabbit_fifo.erl +++ b/src/rabbit_fifo.erl @@ -1418,7 +1418,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), @@ -1427,8 +1427,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], |