Skip to content

Commit 3349321

Browse files
committed
Local shovels: fix credit flow
1 parent 02fcbc0 commit 3349321

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

deps/rabbitmq_shovel/src/rabbit_local_shovel.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -719,7 +719,7 @@ handle_credit_reply({credit_reply, CTag, DeliveryCount, Credit, _Available, _Dra
719719
current => Current#{queue_states => QState}}},
720720
handle_queue_actions(Actions, State);
721721
none when Credit =:= 0 andalso
722-
CCredit > 0 ->
722+
CCredit >= 0 ->
723723
{ok, QState, Actions} = rabbit_queue_type:credit(QName, CTag, DeliveryCount, MaxLinkCredit, false, QState0),
724724
State = State0#{source => Src#{credit => MaxLinkCredit,
725725
at_least_one_credit_req_in_flight => true,

0 commit comments

Comments
 (0)