diff options
| author | kjnilsson <knilsson@pivotal.io> | 2019-09-30 17:02:19 +0100 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2019-09-30 17:02:19 +0100 |
| commit | afe99c9f342a32584d973ebbeaf0245fe9d23ab4 (patch) | |
| tree | adf6df1b037012f76b64f084f9d5ba8b0e17c921 /src | |
| parent | 1101eb6af3f11b964104ad0b7336eeebb9d88764 (diff) | |
| download | rabbitmq-server-git-afe99c9f342a32584d973ebbeaf0245fe9d23ab4.tar.gz | |
Fix typo
That would cause the wrong commands to be resent by the channel.
Diffstat (limited to 'src')
| -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(), |