-
-
Notifications
You must be signed in to change notification settings - Fork 9.6k
[Messenger] Add Beanstalkd bridge #36582
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
75032c8
to
30be838
Compare
private $connection; | ||
private $serializer; | ||
|
||
public function __construct(Connection $connection, SerializerInterface $serializer) |
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.
Serializer can be nullable here no?
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.
Fixed.
1b53ed7
to
2a5bbf3
Compare
2a5bbf3
to
b34ef75
Compare
3bd5d9c
to
de8f23d
Compare
PR rebased with master. I don't understand why the Travis PHP 7.2 build fails with the message I've been using it for months on production and it is working great. |
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.
Haven't had time to do a full review. Just spotted one change for now.
@@ -19,6 +19,7 @@ | |||
"php": ">=7.2.5", | |||
"psr/log": "~1.0", | |||
"symfony/amqp-messenger": "^5.1", | |||
"symfony/beanstalkd-messenger": "^5.2", |
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.
Should be removed. The idea is to add it only when needed.We do have AMQP for BC reasons.
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.
Oh right, removed.
de8f23d
to
0c83c5d
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.
LGTM (with some very minor comments)
@@ -0,0 +1,12 @@ | |||
Beanstalkd Messenger | |||
=============== |
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.
Missing some =
chars
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 added the missing =
chars.
* * ttr: the message time to run before it is put back in the ready queue (in seconds) | ||
*/ | ||
private $configuration; | ||
|
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.
blank line can be removed
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.
Removed.
0c83c5d
to
e786645
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.
@X-Coder264 Can you work on fixing the test now? I suppose that we need to install Beanstalkd on Travis.
@fabpot You mean this failure? https://travis-ci.org/github/symfony/symfony/jobs/717325508
And all the Beanstalkd bridge tests pass there. The PHP 7.2 build does not do that, it just runs
I'm not familiar with your Travis CI setup so I'll have to dig a bit deeper into it to check why |
@X-Coder264 You need to add |
e786645
to
8e6d0df
Compare
Thanks for the tip - I've added it. |
Thank you @X-Coder264. |
@fabpot Thanks for the merge. I'll create a PR for the documentation this weekend. |
On a project at work we use Beanstalkd and we wanted to start using Messenger with it so I've written this bridge/transport. Any feedback is highly appreciated.