Skip to content

Commit 9eaf9af

Browse files
committed
Shovel bugfix: avoid duplicated count of confirmed messages for local shovels
1 parent d5f9ff2 commit 9eaf9af

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
@@ -388,9 +388,7 @@ forward(Tag, Msg0, #{dest := #{current := #{queue_states := QState} = Current} =
388388
on_confirm when length(Queues) > 0 ->
389389
State2;
390390
on_publish ->
391-
decr_remaining(
392-
1,
393-
record_confirms([{Tag, Tag}], State2));
391+
record_confirms([{Tag, Tag}], State2);
394392
_ ->
395393
decr_remaining(1, State2)
396394
end),

0 commit comments

Comments
 (0)