[Messenger] [Amqp] Handle AMQPConnectionException when publishing a message. #54167
Conversation
|
Hey! Thanks for your PR. You are targeting branch "7.1" but it seems your PR description refers to branch "6.4". Cheers! Carsonbot |
carsonbot
changed the title
jwage
force-pushed
the
amqp-connection-exception-retries
branch
from
0ea9ca5
to
1dfcd20
Compare
| if (++$retries <= $maxRetries) { | ||
| $this->clear(); | ||
|
|
||
| goto retry; |
There was a problem hiding this comment.
This will cost years of public bashing, but I guess we can afford it 🥲
There was a problem hiding this comment.
hehehe I like it too. I feel like imo it reads better than a loop specifically for retry logic.
chalasr
force-pushed
the
amqp-connection-exception-retries
branch
from
6479742
to
f123370
Compare
|
Thank you @jwage. |
|
Lovely. Thank you |
|
@nicolas-grekas @chalasr @Nyholm thinking more about this. Does this retry open up the possibility for a double publish? What if the write succeeds on the server but the client loses the connection and exception is thrown before getting the response to the write? Then we retry and double publish. Since this isn't idempotent and we have no guarantees, I don't think we can generically retry. @dunglas see the above. This is related to our discussion about not being able to safely retry non idempotent queries automatically in Doctrine. Asked here as well php-amqp/php-amqp#548 |
If you have a message handler that dispatches messages to another queue, you can encounter
AMQPConnectionExceptionwith the message "Library error: a SSL error occurred" or "a socket error occurred" depending on if you are using tls or not or if you are running behind a load balancer or not.You can manually reproduce this issue by dispatching a message where the handler then dispatches another message to a different queue, then go to rabbitmq admin and close the connection manually, then dispatch another message and when the message handler goes to dispatch the other message, you will get this exception:
TODO: