|
AMQPQueue::consumeConsume messages from a queue Description
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. Parameters
Errors/ExceptionsThrows AMQPChannelException if the channel is not open. Throws AMQPConnectionException if the connection to the broker was lost. Return ValuesExamples
Example #1 AMQPQueue::consume example
<?php |