diff options
| author | David Ansari <david.ansari@gmx.de> | 2021-10-28 19:03:44 +0200 |
|---|---|---|
| committer | David Ansari <david.ansari@gmx.de> | 2021-10-28 19:03:44 +0200 |
| commit | f818b4626d29597c8c1dab875c2c7674ec4b9902 (patch) | |
| tree | 35f6d441c884c36b9992693198bb39bfff638662 | |
| parent | 7511a13ba641935d33ce03d915c683403a7415fe (diff) | |
| download | rabbitmq-server-git-quorum-queue-dead-letter-order.tar.gz | |
Remove duplicate codequorum-queue-dead-letter-order
last_msg_id gets already set to LastId in update_consumer()
| -rw-r--r-- | deps/rabbit/src/rabbit_fifo_client.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/deps/rabbit/src/rabbit_fifo_client.erl b/deps/rabbit/src/rabbit_fifo_client.erl index 7ac1d7ba6e..9cb7b2b0b0 100644 --- a/deps/rabbit/src/rabbit_fifo_client.erl +++ b/deps/rabbit/src/rabbit_fifo_client.erl @@ -762,8 +762,7 @@ handle_delivery(Leader, {delivery, Tag, [{FstId, _} | _] = IdMsgs}, State0#state{consumer_deliveries = update_consumer(Tag, LastId, length(IdMsgs), - C#consumer{last_msg_id = LastId}, - CDels0)}) + C, CDels0)}) end. transform_msgs(QName, QRef, Msgs) -> |