php マニュアル

version PHP 4.1.0 - PHP 5.x.x (newer)

PHP   Pear   MySQL  

AMQPQueue::consume

(PECL amqp >= Unknown)

AMQPQueue::consumeメッセージをキューから取得する

説明

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

ブロック関数です。キューからの次のメッセージが取得できるようになったら読み込み、 そしてそれをコールバックに渡します。

パラメータ

callback

取得したメッセージを渡すコールバック関数。 パラメータとして AMQPEnvelope を受け取ることが必須で、 オプションの二番目のパラメータとしてメッセージの取得元の AMQPQueue を受け取ることもできます。

AMQPQueue::consume() は、 コールバック関数が FALSE を返すまで PHP スクリプトに処理スレッドを戻しません。

flags

フラグ AMQP_NOACK のビットマスク。

エラー / 例外

チャネルが開いていない場合に AMQPChannelException をスローします。

ブローカへの接続が途切れた場合に AMQPConnectionException をスローします。

返り値

例1 AMQPQueue::consume() の例

<?php

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

     
$channel = new AMQPChannel($connection);

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

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

     
$i 0;
     function 
processMessage($envelope$queue) {
        global 
$i;
        echo 
"Message $i: " $envelope->getBody() . "\n";
        
$i++;
        if (
$i 10) {
            
// 10 件ごとに解放します
            
return false;
        }
     }

     
// メッセージをキューから取得します
     
$queue->consume("processMessage");

     
?>


 
 

Add Comment

※半角英数

Add Comment  (注) 修正するときは、以前入力したKeyを入力してください。(単純なキーの場合、上書きされてしまいます)

 
 

Comment

コメントはまだ登録されていません。一番乗りで関数の利用方法を書いてみませんか?

 
 
 
 
New Entry

php/function.preg-match.html

先頭3桁が070、080、090のいずれかで始まる電話番号にマッチするパターン

Show Detail

php/function.mb-strimwidth.html

文字コードを指定して、全角半角が混在している文字列を短縮。

Show Detail

mysql/index.html

H7EnFK dvyozfiiutul, [url=http://mcfonuzjslbq.com/]mcfonuzjslbq[/url], [link=http://rosbokkudfzh.com/]rosbokkudfzh[/link], http://stjnnhsdhiyo.com/

Show Detail

: JAPANESE/index.html

Замечательно, это весьма ценное сообщение Очень любопытно :) _________________________________________________________________________ http://trustavia.ru/communication/forum/user/4652/ http://omax.ru/communication/forum/user/1089/

Show Detail

index.html

はじめてのコメント

Show Detail