How on PHP cancel consumer in RabbitMQ?

Question

I have next code: ``` <?php // callback function for recive the message and canceling consumer function consumer(\AMQPEnvelope $envelope, \AMQPQueue $queue) { $queue->ack($envelope->getDeliveryTag()); $queue->cancel($envelope->getCorrelationId()); echo "Message was recived and consumer will be canceled by consumer tag: {$envelope->getCorrelationId()}
"; } // generating uniqie exchange and queue $correlationId = uniqid(str_replace('.', '', (string)microtime(TRUE)) . '_'); $queueName = "databus_response_{$correlationId}"; $consumerTag = "consumer_tag_{$correlationId}"; // establesh connection $connection = new \AMQPConnection(array('host'=>'127.0.0.1', 'user'=>'guest', 'password'=>'guest')); $connection->connect(); $channel = new \AMQPChannel($connection); // declare exchange $exchange = new \AMQPExchange($channel); $exchange->setFlags(AMQP_AUTODELETE); $exchange->setType(AMQP_EX_TYPE_TOPIC); $exchange->setName($queueName); $exchange->declareExchange(); // declare queue $queue = new \A…

Accepted Answer

just return `false` from consumer callback when you want to stop consuming.

From AMQPQueue.php stub file:

The AMQPQueue::consume() will not return the processing thread back to the PHP script until the callback function returns FALSE.

P.S.: sad to say that `php-amqp` extension still lack of good documentation, but you can always read method annotation in stub files or read a bit outdated documentation on official php site in Polish language here - http://www.php.net/manual/pl/book.amqp.php (don't worry, nobody translated it, so all sensitive doc is in English).

How on PHP cancel consumer in RabbitMQ?

Solution

Problem