diff options
| author | Loïc Hoguin <lhoguin@vmware.com> | 2021-08-16 13:30:14 +0200 |
|---|---|---|
| committer | Loïc Hoguin <lhoguin@vmware.com> | 2021-08-16 13:30:14 +0200 |
| commit | 31d908ddcb65aa7ba66e119abd6d7a7d2b0710ac (patch) | |
| tree | af599d695e1452a3e5943f762636955c6086c9a7 | |
| parent | f6947c17575c49c8b3ebdd9b3d55a6a3e079ac89 (diff) | |
| download | rabbitmq-server-git-old-index-per-queue-delivers.tar.gz | |
Fix index for per-queue deliversold-index-per-queue-delivers
| -rw-r--r-- | deps/rabbit/src/rabbit_queue_index.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/deps/rabbit/src/rabbit_queue_index.erl b/deps/rabbit/src/rabbit_queue_index.erl index cdd00c9326..37e1072328 100644 --- a/deps/rabbit/src/rabbit_queue_index.erl +++ b/deps/rabbit/src/rabbit_queue_index.erl @@ -843,9 +843,9 @@ action_to_entry(RelSeq, Action, JEntries) -> end}; ({Pub, no_del, no_ack}) when Action == del -> {set, {Pub, del, no_ack}}; - ({no_pub, del, no_ack}) when Action == ack -> + ({no_pub, _del, no_ack}) when Action == ack -> {set, {no_pub, del, ack}}; - ({?PUB, del, no_ack}) when Action == ack -> + ({?PUB, _del, no_ack}) when Action == ack -> {reset, none} end. @@ -1084,7 +1084,7 @@ entry_to_segment(RelSeq, {Pub, Del, Ack}, Initial) -> Binary = <<?REL_SEQ_ONLY_PREFIX:?REL_SEQ_ONLY_PREFIX_BITS, RelSeq:?REL_SEQ_BITS>>, case {Del, Ack} of - {del, ack} -> [[Binary, Binary] | Initial]; + {_del, ack} -> [[Binary, Binary] | Initial]; _ -> [Binary | Initial] end end, |