diff options
| -rw-r--r-- | src/rabbit_fifo.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_fifo.erl b/src/rabbit_fifo.erl index 6f168bf78e..609fa0111c 100644 --- a/src/rabbit_fifo.erl +++ b/src/rabbit_fifo.erl @@ -1380,8 +1380,8 @@ send_log_effect({CTag, CPid}, IdxMsgs) -> end}. reply_log_effect(RaftIdx, MsgId, Header, Ready, From) -> - {log, RaftIdx, - fun({enqueue, _, _, Msg}) -> + {log, [RaftIdx], + fun([{enqueue, _, _, Msg}]) -> [{reply, From, {wrap_reply, {dequeue, {MsgId, {Header, Msg}}, Ready}}}] end}. |