prolic / humus-amqp
PHP-AMQP library with RabbitMQ Extensions
Fund package maintenance!
Patreon
Installs: 176 612
Dependents: 5
Suggesters: 0
Security: 0
Stars: 76
Watchers: 15
Forks: 17
Open Issues: 5
Requires
- php: ^7.4 || ^8.0
- ext-json: *
- beberlei/assert: ^3.2.7
- marc-mabe/php-enum: ^4.7
- psr/log: ^1.0 || ^2.0 || ^3.0
Requires (Dev)
- ext-pcntl: *
- laminas/laminas-servicemanager: ^3.0
- malukenho/docheader: ^0.1.8 || ^1.0
- php-amqplib/php-amqplib: ^3.0
- php-coveralls/php-coveralls: ^2.4
- php-mock/php-mock-phpunit: ^2.6
- phpspec/prophecy: ^1.17
- phpspec/prophecy-phpunit: ^2.0
- phpunit/phpunit: ^9.6
- prooph/php-cs-fixer-config: ^0.5.0
- psr/container: ^1.0
- sandrokeil/interop-config: ^1.0 || ^2.0
- symfony/console: ^5.4 || ^6.3
Suggests
- ext-amqp: >= 1.9.3 For usage together with php amqp extension
- ext-pcntl: For process control management
- php-amqplib/php-amqplib: >= 2.11 For usage together with php-amqplib
- psr/container: For usage of provided factories
- sandrokeil/interop-config: For usage of provided factories
- symfony/console: For usage of the provided console tool
Conflicts
This package is auto-updated.
Last update: 2024-10-25 10:32:09 UTC
README
PHP 7.4 AMQP library
Documentation powered by Read the Docs.
Overview
PHP 7.4+ AMQP libray supporting multiple drivers and providing full-featured Consumer, Producer, and JSON-RPC Client / Server implementations.
The JSON-RPC part implements JSON-RPC 2.0 Specification.
Current supported drivers are: php-amqp and PhpAmqpLib.
php-amqp needs at least to be v1.9.3 php-amqplib needs at least to be v3
This library ships with psr/container
factories that help you setting up everything.
Zend Framework and Symfony Framework Integration
Installation
You can install prolic/humus-amqp via composer by adding "prolic/humus-amqp": "^2.0"
as requirement to your composer.json.
Usage
Exchange
$exchangeName = 'test-exchange';
$exchange = ExchangeFactory::$exchangeName($container);
$exchange->publish('test-message');
Queue
$queueName = 'test-queue';
$queue = QueueFactory::$queueName($container);
$message = $queue->get();
$queue->ack($message->getDeliveryTag());
Producer
$producerName = 'test-producer';
$producer = ProducerFactory::$producerName($container);
$producer->confirmSelect();
$producer->publish(['foo' => 'bar'], 'my-routing-key');
$producer->waitForConfirm();
JSON RPC Client
$clientName = 'my-client';
$client = JsonRpcClientFactory::$clientName($container);
$client->addRequest(new JsonRpcRequest('my-server', 'method', ['my' => 'params'], 'id-1'));
$client->addRequest(new JsonRpcRequest('my-server', 'method', ['my' => 'other_params'], 'id-2'));
$responseCollection = $client->getResponseCollection();
JSON RPC Server
$serverName = 'my-server';
$server = JsonRpcServerFactory::$serverName($container);
$server->consume();
Notes
Upgrade from 1.x to 1.4
Before: If auto_setup_fabric
was enabled, the queue and exchange binding was done automatically. The exchanges would also get created. Anonymous queues required to have auto_setup_fabric
set to true.
New: If auto_setup_fabric
is enabled or the queue is anonymous (has no name), the queue gets created and binding is done, but no exchanges are created. If you want to enable creating of depending exchanges (including exchange binding), set the new argument auto_setup_exchanges
to true.
This is a slight BC break, but the old behaviour was so problematic, that I had to make this change either way.
AMQP-Extension
- We recommend using php-amqp >=v1.9.3 or compiling it from master, if you encounter any problems with the amqp extension, check their issue tracker, first.
The ext-amqp driver is the most performant.
PhpAmqpLib
-
When using php-amqplib as driver, it's worth point out, that a StreamConnection (same goes for SSLConnection) does not have the possibility to timeout. If you want to let the consumer timeout, when no more messages are received, you should use the SocketConnection instead (assuming you don't need an SSL connection).
-
When using php-amqplib as driver and you're using the LazyConnection, you should not create the channel yourself, call instead
$channel = $connection->newChannel()
Support
- File issues at https://github.com/prolic/HumusAmqp/issues.
- Say hello in the HumusAmqp gitter chat.
Contribute
Please feel free to fork and extend existing or add new plugins and send a pull request with your changes! To establish a consistent code quality, please provide unit tests for all your changes and may adapt the documentation.
License
Released under the MIT.