-
Notifications
You must be signed in to change notification settings - Fork 25
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
Better interface to integrate RabbitMQ #19
Comments
@dfeyer when you write "for each message" you are talking about The main entry point for these methods is |
Yes, the AMQP prototocol is heavy and if we can avoid the to repeat the connection process for every message, it could be really nice |
I push a new version of my RabbitMQ integration, a bit more efficiant by using AMQP wait function and proper QoS configuration. |
I have a project that need to use RabbitMQ, currently the JobQueue package, connect to the queue server for each message, it's not really efficient.
RabbitMQ offers API to use closure to consume message, with connection/deconnection between each message, its more efficiant and allow more monitoring of the consumer, because the connection lives a long time.
Any idea how we can extend the JobQueue package to support this kind of case ?
See this consumer example https://github.com/php-amqplib/php-amqplib/blob/master/demo/amqp_consumer.php#L67
The text was updated successfully, but these errors were encountered: