Queue Interop based wrapper for rabbitmq-cli-consumer.
composer makasim/php-fpm-queue:0.1.x-dev queue-interop/queue-interop:0.7.x-dev queue-interop/amqp-interop:0.8.x-devAn executable:
<?php
#!/usr/bin/env php
# executable.php
use Makasim\RabbitmqCliConsumer\RabbitmqCliConsumerConnectionFactory;
require_once __DIR__.'/vendor/autoload.php';
$context = (new RabbitmqCliConsumerConnectionFactory())->createContext();
$queue = $context->createQueue($argv[1]);
$consumer = $context->createConsumer($queue);
if ($message = $consumer->receiveNoWait()) {
// process message
$consumer->acknowledge($message);
// or
//$consumer->reject($message);
}Run
rabbitmq-cli-consumer --verbose --url amqp://guest:guest@localhost --include --pipe --queue myqueue --executable "executable.php myqueue"