Skip to content

Commit 872da24

Browse files
dcorbachomergify[bot]
authored andcommitted
Amqp10 shovel: retry with insufficient_credit error (#14569)
(cherry picked from commit 1e3e58a)
1 parent 5a16693 commit 872da24

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)