Skip to content

Commit a3db40c

Browse files
committed
Shovel bugfix: avoid duplicated count of confirmed messages for local shovels
1 parent 4517b84 commit a3db40c

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

deps/rabbitmq_shovel/src/rabbit_local_shovel.erl

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -400,9 +400,7 @@ forward(Tag, Msg0, #{dest := #{current := #{queue_states := QState} = Current} =
400400
on_confirm when length(Queues) > 0 ->
401401
State2;
402402
on_publish ->
403-
decr_remaining(
404-
1,
405-
record_confirms([{Tag, Tag}], State2));
403+
record_confirms([{Tag, Tag}], State2);
406404
_ ->
407405
decr_remaining(1, State2)
408406
end),

0 commit comments

Comments
 (0)