root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 9 Packages Projects Releases Wiki Activity

Amqp10 shovel: retry with insufficient_credit error (#14569)

This commit is contained in:
D Corbacho 2025-09-19 14:37:39 +02:00 committed by GitHub
parent b3a58b86ed
commit 1e3e58a29b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
deps/rabbitmq_shovel/src/rabbit_amqp10_shovel.erl vendored
View File

@ -359,7 +359,7 @@ send_msg(Link, Msg) ->
ok; ok;
{error, insufficient_credit} -> {error, insufficient_credit} ->
receive {amqp10_event, {link, Link, credited}} -> receive {amqp10_event, {link, Link, credited}} ->
ok = amqp10_client:send_msg(Link, Msg) send_msg(Link, Msg)
after ?LINK_CREDIT_TIMEOUT -> after ?LINK_CREDIT_TIMEOUT ->
{stop, credited_timeout} {stop, credited_timeout}
end end