diff options
| -rw-r--r-- | src/rabbit_fifo_client.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_fifo_client.erl b/src/rabbit_fifo_client.erl index 7fd0a664f4..afd7926d80 100644 --- a/src/rabbit_fifo_client.erl +++ b/src/rabbit_fifo_client.erl @@ -748,9 +748,9 @@ add_command(_, _, [], Acc) -> add_command(Cid, settle, MsgIds, Acc) -> [rabbit_fifo:make_settle(Cid, MsgIds) | Acc]; add_command(Cid, return, MsgIds, Acc) -> - [rabbit_fifo:make_settle(Cid, MsgIds) | Acc]; + [rabbit_fifo:make_return(Cid, MsgIds) | Acc]; add_command(Cid, discard, MsgIds, Acc) -> - [rabbit_fifo:make_settle(Cid, MsgIds) | Acc]. + [rabbit_fifo:make_discard(Cid, MsgIds) | Acc]. set_timer(#state{servers = [Server | _]} = State) -> Ref = erlang:send_after(?TIMER_TIME, self(), |