AMQPQueue::get

(PECL amqp >= Unknown)

AMQPQueue::get — 次のメッセージをキューから取得する

説明

public mixed AMQPQueue::get ([ int $flags ] )

次のメッセージをキューから取得します。もしメッセージがキューになければ、メッセージを取得せずすぐに FALSE を返します。これは、 AMQPQueue::consume() メソッドの非ブロック版です。

今のところ、flags パラメータに渡すフラグとしてサポートしているのは AMQP_AUTOACK だけです。このフラグを渡した場合、返されたメッセージのフレームをクライアントに送信すると、自動的にブローカによる受け付けマークがつけられます。

パラメータ

flags: メソッドコールの際にサポートしているフラグのビットマスク。今のところ、サポートしているフラグは AMQP_AUTOACK だけです。この値を省略すると、amqp.auto_ack の値を使います。

返り値

キューから取得したメッセージを表す AMQPEnvelope のインスタンス、あるいは FALSE を返します。

例

例1 AMQPQueue::get() の例


<?php

   /* デフォルトの設定で接続を作成します */
   $connection = new AMQPConnection();
   $connection->connect();

   $channel = new AMQPChannel($connection);

   /* キューオブジェクトを作成します */
   $queue = new AMQPQueue($channel);

   // キューを宣言します
   $queue->declare('myqueue');

   // メッセージを取得します
   $messages = $queue->get(AMQP_AUTOACK);

   echo $message->getBody();

   ?>