diff options
| author | kjnilsson <knilsson@pivotal.io> | 2019-04-11 16:53:40 +0100 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2019-04-11 16:53:40 +0100 |
| commit | 2ad83292a53a7d86ad56c7adff245d28989e9b32 (patch) | |
| tree | 89cd34c11fbc1e684ad7ce03462e35ac21ddabc1 /src | |
| parent | e2919659cb0e6537d4b43c3ad7cebf08ad1414be (diff) | |
| download | rabbitmq-server-git-2ad83292a53a7d86ad56c7adff245d28989e9b32.tar.gz | |
correct log effect type
Diffstat (limited to 'src')
| -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}. |