From fa1ad00f0059f3a33252a6921079eb40319f16e2 Mon Sep 17 00:00:00 2001 From: Bradley Holt Date: Fri, 26 Aug 2011 16:53:23 +0000 Subject: [PATCH] Add examples to AMQPQueue::get and AMQPQueue::ack documentation. git-svn-id: https://svn.php.net/repository/phpdoc/en/trunk@315574 c90b9560-bf6c-de11-be94-00142212c4b1 --- reference/amqp/amqpqueue/ack.xml | 69 ++++++++++++++++++++++++++++++++ reference/amqp/amqpqueue/get.xml | 31 ++++++++++++++ 2 files changed, 100 insertions(+) diff --git a/reference/amqp/amqpqueue/ack.xml b/reference/amqp/amqpqueue/ack.xml index d787f6073f..b23560c6d8 100644 --- a/reference/amqp/amqpqueue/ack.xml +++ b/reference/amqp/amqpqueue/ack.xml @@ -50,6 +50,75 @@ &return.success; + + + &reftitle.examples; + + + <methodname>AMQPQueue::ack</methodname> example with <methodname>AMQPQueue::get</methodname> + +connect(); + +/* create a queue object */ +$queue = new AMQPQueue($connection); + +//declare the queue +$queue->declare('myqueue'); + +//get the next message, but don't mark it as delivered +$message = $queue->get(AMQP_NOACK); + +echo $message['msg']; + +//acknowledge the message as received +$queue->ack($message['delivery_tag']); + +?> +]]> + + + + <methodname>AMQPQueue::ack</methodname> example with <methodname>AMQPQueue::consume</methodname> + +connect(); + +/* create a queue object */ +$queue = new AMQPQueue($connection); + +//declare the queue +$queue->declare('myqueue'); + +$options = array( + 'min' => 1, + 'max' => 10, + 'ack' => false +); + +//get the messages, but don't mark them as delivered +$messages = $queue->consume($options); + +foreach ($messages as $message) { + echo $message['message_body']; + //acknowledge the message as received + $queue->ack($message['delivery_tag']); +} + +?> +]]> + + + +