-
-
Notifications
You must be signed in to change notification settings - Fork 9.6k
[Messenger] [Redis] Fixed problem where worker stops handling messages on first empty message #48837
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
Conversation
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 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please associate your commiter email with your Github account
src/Symfony/Component/Messenger/Bridge/Redis/Tests/Transport/RedisExtIntegrationTest.php
Outdated
Show resolved
Hide resolved
src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisReceiver.php
Outdated
Show resolved
Hide resolved
src/Symfony/Component/Messenger/Bridge/Redis/Tests/Transport/RedisExtIntegrationTest.php
Outdated
Show resolved
Hide resolved
38c9b3a
to
ab0f1d4
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I've rebased + squashed your PR to have a clean git history. Don't forget to fetch before working again on the patch if needed.
About the patch itself, I don't know the topic well enough. Anyone else willing to review in depth?
Will do yes. Ping @alexander-schranz also since you provided some guidance in the linked issue (no hurry) |
Is there anything I (or anyone else) can do to help with this PR? I'm having the same problem, and this problem is also present in case of an invalid message (can't decode a JSON for example), it should never happen but I have an external system that can push in a stream read by Symfony Messenger, so it would be better if the transport to expect the possibility of an invalid or empty message and rejects this message. |
Same problem, any update? |
…s on first empty message
ab0f1d4
to
ce103f1
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I updated the PR to use reject.
Thank you @jvmanji. |
Fixed problem where worker stops handling messages on first empty message.