root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Local shovel: remove unused clause

This commit is contained in:
Diana Parra Corbacho 2025-08-13 13:54:52 +02:00
parent 07a085365e
commit edf0e3c1ff
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
deps/rabbitmq_shovel/src/rabbit_local_shovel.erl vendored
View File

@ -598,10 +598,6 @@ settle(Op, DeliveryTag, Multiple,
%%
%% Returns a tuple of acknowledged pending acks and remaining pending acks.
%% Sorts each group in the youngest-first order (descending by delivery tag).
%% The special case for 0 comes from the AMQP 0-9-1 spec: if the multiple field is set to 1 (true),
%% and the delivery tag is 0, this indicates acknowledgement of all outstanding messages (by a client).
collect_acks(UAMQ, 0, true) ->
{lists:reverse(?QUEUE:to_list(UAMQ)), ?QUEUE:new()};
collect_acks(UAMQ, DeliveryTag, Multiple) ->
collect_acks([], [], UAMQ, DeliveryTag, Multiple).