Thumper

RabbitMQ abstraction for queues and workers.

Install

Via Composer

$ composer require codin/thumper

Examples

$connection = newPhpAmqpLib\Connection\AMQPLazyConnection('localhost', '5672', 'username', 'password');
$exchange = newCodin\Thumper\Config\Exchange('my-exchange-name', PhpAmqpLib\Exchange\AMQPExchangeType::DIRECT);
$producer = newCodin\Thumper\Producer($connection, $exchange);
$producer->publish('some message');

$connection = newPhpAmqpLib\Connection\AMQPLazyConnection('localhost', '5672', 'username', 'password');
$exchange = newCodin\Thumper\Config\Exchange('my-exchange-name', PhpAmqpLib\Exchange\AMQPExchangeType::DIRECT);
$queue = newCodin\Thumper\Config\Queue('my-queue-name');
$options = newCodin\Thumper\Config\Consumer($exchange, $queue);
$consumer = newCodin\Thumper\Consumer($connection, $options);
$callback = staticfunction (PhpAmqpLib\Message\AMQPMessage$message): void {
echo$message->getBody(); // some message$message->ack();
};
$consumer->consume($callback);

Testing

$ composer test