# フレームワーク

Zend_Queueは、 待ち行列サービスの詳細を隠す代理です。 待ち行列サービスは、Zend_Queue_Adapter_<service>によって表現されます。 たとえば、Zend_Queue_Adapter_Dbは、 メッセージを格納・読み出しするためにデータベーステーブルを使う待ち行列です。

下記は、待ち行列システムのためにデータベーステーブルを利用する例です:

    $options = array(
        'name'          => 'queue1',
        'driverOptions' => array(
            'host'      => '127.0.0.1',
            'port'      => '3306',
            'username'  => 'queue',
            'password'  => 'queue',
            'dbname'    => 'queue',
            'type'      => 'pdo_mysql'
        )
    );

    // データベース待ち行列を作成します。
    // Zend_Queue はクラス名として Zend_Queue_Adapter_ の後に 'Db' を付加します。
    $queue = new Zend_Queue('Db', $options);

Zend_QueueコンストラクタはZend_Queue_Adapter_Dbを作成して、 構成設定値でアダプタを初期化します。

各々のアダプタに認められた構成設定値は、 アダプタの注意で示されます

Zend_Queueは クラスZend_Queue_Message_Iteratorを用いてメッセージを返します。 そして、それはSPL Iterator及びCountableの実装です。 Zend_Queue_Message_Iteratorは、 Zend_Queue_Messageオブジェクトの配列を含みます。

    $messages = $queue->receive(5);
    foreach ($messages as $i => $message) {
        echo "$i) Message => ", $message->body, "\n";
    }

投げられるどんな例外も、クラスZend_Queue_Exceptionです。

## 導入

Zend_Queueは、 アダプタを表現する代理クラスです。

send()や count($queue)、そして receive()メソッドは、 待ち行列と相互に作用するために、それぞれのアダプタによって使用されます。

createQueue()及び deleteQueue()メソッドは待ち行列を管理するために使われます。

## アダプタの間の互換性

Zend_Queueによってサポートされる待ち行列サービスは、 同じ関数をサポートするとは限りません。 例えば、Zend_Queue_Adapter_Array及び Zend_Queue_Adapter_Dbは全ての関数をサポートしますが、 一方、Zend_Queue_Adapter_Activemqは 待ち行列の一覧や削除、そしてメッセージのカウントをサポートしません。

Zend_Queue::isSupported()または Zend_Queue::getCapabilities()を使って どんな関数がサポートされるか判定できます。

- createQueue() - 待ち行列を作成

- deleteQueue() - 待ち行列を削除

- send() - メッセージを送信

  send()はアダプタ全てで利用可能なわけではありません; Zend_Queue_Adapter_Nullはsend()をサポートしません。

- receive() - メッセージを受信

  receive()はアダプタ全てで利用可能なわけではありません; Zend_Queue_Adapter_Nullはreceive()をサポートしません。

- deleteMessage() - メッセージを削除

- count() - 待ち行列内のメッセージ数をカウント

- isExists() - 待ち行列が存在するかチェック

receive()メソッドは、 待ち行列と相互に作用するために、それぞれのアダプタによって使用されます。

createQueue()及び deleteQueue()メソッドは待ち行列を管理するために使われます。