jwage / phpamqplib-messenger
Symfony messenger transport for the php-amqplib/php-amqplib library.
Installs: 165
Dependents: 0
Suggesters: 0
Security: 0
Stars: 23
Watchers: 5
Forks: 2
Open Issues: 3
Type:symfony-bundle
Requires
- php: ^8.3
- php-amqplib/php-amqplib: ^3.7
- symfony/framework-bundle: ^5.4 || ^6.4 || ^7.0
- symfony/messenger: ^5.4 ||^6.3 || ^7.0
Requires (Dev)
- doctrine/coding-standard: ^13.0
- phpunit/phpunit: ^12.1
- psalm/plugin-phpunit: ^0.19.5
- psalm/plugin-symfony: ^5.2
- symfony/phpunit-bridge: ^7.2
- vimeo/psalm: ^6
This package is auto-updated.
Last update: 2025-04-19 03:16:52 UTC
README
This bundle adds support for php-amqplib/php-amqplib
to Symfony Messenger, providing an alternative way to connect to RabbitMQ using a pure PHP library instead of the php-amqp C extension.
Installation
composer require jwage/phpamqplib-messenger
Make sure the bundled is enabled in config/bundles.php
:
return [ // ... Jwage\PhpAmqpLibMessengerBundle\PhpAmqpLibMessengerBundle::class => ['all' => true], ];
The minimum configuration required is the transports name and the DSN.
# config/packages/messenger.yaml framework: messenger: transports: orders: dsn: 'phpamqplib://guest:guest@localhost:5672/myvhost/orders'
The configuration above will create an exchange named orders
and bind a queue named orders
to it within the vhost myvhost
.
Documentation
For detailed documentation, including advanced configuration options, features, and usage examples, please see the documentation.
Why use this bundle?
There are several reasons why you might prefer to use the php-amqplib/php-amqplib
library over the php-amqp
C extension for connecting to RabbitMQ in Symfony Messenger:
-
Asynchronous Consumers: The
php-amqplib
library properly implements asynchronous consumers, which allows for more efficient message handling. This is particularly useful for advanced use cases where you need to handle a large number of messages concurrently. -
Active Maintenance: Both
php-amqplib
andphp-amqp
are actively maintained by VMware. However,php-amqplib
is often preferred for its flexibility and ease of use in PHP applications. -
PHP Version Compatibility: Using
php-amqplib
makes upgrading PHP versions easier, as it does not rely on a C extension that may have compatibility issues with newer PHP versions. -
Efficient Message Streaming: The
php-amqplib
library allows for proper streaming of messages from the server, avoiding the inefficiencies of constant polling withget()
. This means that you can maintain an open stream connection and control how long to wait for messages, which is not possible with thephp-amqp
extension. -
Safe Worker Shutdown: With
php-amqplib
, you can safely stop your workers usingpcntl
signals, ensuring that your handlers do not get shut down mid-message handling. This is a significant advantage over thephp-amqp
extension, where theconsume()
method does not work as expected, leading to potential issues with worker shutdown.
In summary, php-amqplib
provides a more robust and flexible solution for connecting to RabbitMQ in Symfony Messenger, making it the preferred choice for many developers.
License
This bundle is licensed under the MIT License. See the LICENSE file for details.