AMQPQueue::consume

(PECL amqp >= Unknown)

AMQPQueue::consume — Consume messages from a queue

说明

public void AMQPQueue::consume ( callable $callback [, int $flags = AMQP_NOPARAM ] )

Blocking function that will retrieve the next message from the queue as it becomes available and will pass it off to the callback.

参数

callback

A callback function to which the consumed message will be passed. The function must accept at a minimum one parameter, an AMQPEnvelope object, and an optional second parameter the AMQPQueue from which the message was consumed.

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

flags

A bitmask of any of the flags: AMQP_NOACK.

错误/异常

Throws AMQPChannelException if the channel is not open.

Throws AMQPConnectionException if the connection to the broker was lost.

返回值

范例

Example #1 AMQPQueue::consume() example


<?php

     /* Create a connection using all default credentials: */
     $connection = new AMQPConnection();
     $connection->connect();

     $channel = new AMQPChannel($connection);

     /* create a queue object */
     $queue = new AMQPQueue($channel);

     //declare the queue
     $queue->declare('myqueue');

     $i = 0;
     function processMessage($envelope, $queue) {
        global $i;
        echo "Message $i: " . $envelope->getBody() . "\n";
        $i++;
        if ($i > 10) {
            // Bail after 10 messages
            return false;
        }
     }

     // Consume messages on queue
     $queue->consume("processMessage");

     ?>

PHP手册 - N: Consume messages from a queue

用户评论:

peter dot colclough at toolstation dot com (09-Aug-2011 11:10)

Using AMQP_consume, against a RabbitMQ server, actually stuffs memory. It will work in a loop, or on a constant recall, so long as your exchange/queue and messages are set to durable. However, it will alo make the system unusable within a couple of minutes. Using get(), all is fine. I think this may be a bugette in teh PHP access code... ff to take a look.

hlopetz at gmail dot com (11-May-2011 07:32)

you shouldn't use AMQPQueue::consume() if you have to get _all_ incoming messages. you'll get only "max" number of messages and the queue will be destroyed then. for my amqp.so v0.2.2 this weird behavior is true. use AMQPQueue::get() and use "count" param instead.