-
-
Notifications
You must be signed in to change notification settings - Fork 9.6k
[Messenger] [WIP][Keepalive] keepaliveInterval from KeepaliveReceiverInterface #59238
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: 7.3
Are you sure you want to change the base?
[Messenger] [WIP][Keepalive] keepaliveInterval from KeepaliveReceiverInterface #59238
Conversation
Hey! To help keep things organized, we don't allow "Draft" pull requests. Could you please click the "ready for review" button or close this PR and open a new one when you are done? Note that a pull request does not have to be "perfect" or "ready for merge" when you first open it. We just want it to be ready for a first review. Cheers! Carsonbot |
Hey! I see that this is your first PR. That is great! Welcome! Symfony has a contribution guide which I suggest you to read. In short:
Review the GitHub status checks of your pull request and try to solve the reported issues. If some tests are failing, try to see if they are failing because of this change. When two Symfony core team members approve this change, it will be merged and you will become an official Symfony contributor! I am going to sit back now and wait for the reviews. Cheers! Carsonbot |
As I understand the issue with this solution is that since |
With Could you go into more detail about the possible risks? |
TODO:
Allow to retrieve alarm interval by receiver next to command option
For now we have to pass
--keepalive
option to ConsumeMessagesCommand and FailedMessagesRetryCommand to set alarm interval for application. But \AMQPQueue and amqp transport hasheartbeat
option. Will be nice to allow manage the keepalive interval by receiver so we can use this option and adjust alarm interval automatically by transport (maybe I will make another PR for AmqpTransport, I am working on this).To achieve this I propose to use (new in 7.2) interface KeepaliveReceiverInterface and get keepalive interval from it. If
--keepalive
option was already been passed by command we shouldn't change it. Command option should be more important.(this is my first PR in Symfony, so if I need to do anything more for now, please let me know)