Skip to content

Commit 9318f6b

Browse files
Merge pull request #14575 from rabbitmq/mergify/bp/v4.2.x/pr-14569
Amqp10 shovel: retry with insufficient_credit error (backport #14569)
2 parents 5a16693 + 872da24 commit 9318f6b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

deps/rabbitmq_shovel/src/rabbit_amqp10_shovel.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -359,7 +359,7 @@ send_msg(Link, Msg) ->
359359
ok;
360360
{error, insufficient_credit} ->
361361
receive {amqp10_event, {link, Link, credited}} ->
362-
ok = amqp10_client:send_msg(Link, Msg)
362+
send_msg(Link, Msg)
363363
after ?LINK_CREDIT_TIMEOUT ->
364364
{stop, credited_timeout}
365365
end

0 commit comments

Comments
 (0)