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