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

Shovel bugfix: increase forwarded counter for amqp10 protocol

This commit is contained in:
Diana Parra Corbacho 2025-10-07 16:31:08 +02:00
parent 28f9720a12
commit 646eda0802
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
deps/rabbitmq_shovel/src/rabbit_amqp10_shovel.erl vendored
View File

@ -341,15 +341,16 @@ forward(Tag, Msg0,
Msg3 = amqp10_raw_msg:new(AckMode =/= on_confirm, Tag, iolist_to_binary(Msg2)),
case send_msg(Link, Msg3) of
ok ->
#{dest := Dst1} = State1 = rabbit_shovel_behaviour:incr_forwarded(State),
rabbit_shovel_behaviour:decr_remaining_unacked(
case AckMode of
no_ack ->
rabbit_shovel_behaviour:decr_remaining(1, State);
rabbit_shovel_behaviour:decr_remaining(1, State1);
on_confirm ->
State#{dest => Dst#{unacked => Unacked#{OutTag => Tag}}};
State1#{dest => Dst1#{unacked => Unacked#{OutTag => Tag}}};
on_publish ->
State1 = rabbit_shovel_behaviour:ack(Tag, false, State),
rabbit_shovel_behaviour:decr_remaining(1, State1)
State2 = rabbit_shovel_behaviour:ack(Tag, false, State1),
rabbit_shovel_behaviour:decr_remaining(1, State2)
end);
Stop ->
Stop