corley / queue-rabbitmq
0.0.1
2017-01-24 20:23 UTC
Requires
Requires (Dev)
- corley/queue: ~1
- phpunit/phpunit: ~4.0
This package is not auto-updated.
Last update: 2024-11-09 21:17:11 UTC
README
To use this package your need php-amqplib/php-amqplib
composer require php-amqplib/php-amqplib:~2
Use as adapter
Create the adapter
use Corley\Queue\RabbitMQ\RabbitMQ; $amqp = new AMQPStreamConnection('localhost', 5672, 'username', 'password'); $adapter = new RabbitMQ($amqp);
You can use exchange
and receive timeout options
$adapter = new RabbitMQ($amqp, [ "exchange" => "my_exchange", // send to an exchange "receive_timeout" => 20, // exit after 20 seconds ]);
Set as usual
use Corley\Queue\Queue; $queue = new Queue("my_queue", $adapter); $queue->send(json_encode(["test" => "ok"])); list($receipt, $message) = $queue->receive(); $message = json_decode($message, true); $queue->delete($receipt);
Test suite (functional)
docker run -d --hostname my-rabbit \ -p 5672:5672 -p 15672:15672 --name rabbit \ -e RABBITMQ_DEFAULT_USER=wdalmut \ -e RABBITMQ_DEFAULT_PASS=testtest \ rabbitmq:3-management