非同期的なメッセージ受信

.NET、C++、Java の API を使用して、非同期的にメッセージを受信するには、メッセージリスナー関数を作成して登録します。メッセージがキューに登録されると、このメッセージリスナー関数が QAnywhere によって呼び出されます。メッセージリスナーは、着信メッセージを引数とします。メッセージリスナー内で実行する処理は、アプリケーションによって異なります。たとえば、TestMessage サンプルアプリケーションのメッセージリスナーは、TestMessage のメインウィンドウのメッセージリストに着信メッセージを追加します。

.NET、C++、Java での開発のヒント

受信メッセージの処理過程、メッセージの受信確認中に発生する可能性のあるアプリケーションエラーを防ぐために、QAManager を EXPLICIT_ACKNOWLEDGEMENT モードで使用することをおすすめします。

QAManager が EXPLICIT_ACKNOWLEDGEMENT モードでオープンされている場合、メッセージは正常に処理された後でのみ onMessage メソッドで受信確認されます。この方法では、メッセージの処理中にエラーが発生した場合は受信確認が行われないため、メッセージを再受信できます。

QAManager が IMPLICIT_ACKNOWLEDGEMENT モードでオープンされている場合、onMessage に渡されたメッセージは、onMessage がメッセージを戻すときに暗黙的に受信確認されます。このため、メッセージの処理中にユーザーアプリケーションでエラーが発生した場合でも受信確認が行われるため、メッセージは再受信できせん。

♦ メッセージの非同期的受信 (.NET の場合)

メッセージハンドラーメソッドを実装します。

private void onMessage(QAMessage msg) {
    // Process message.
}

メッセージハンドラーを登録します。

メッセージハンドラーを登録するには、メッセージハンドラーを引数として指定して QAManager.MessageListener オブジェクトを作成します。次に、QAManager.SetMessageListener 関数を使用して、MessageListener を特定のキューに登録します。次の例では、queue-name は QAManager オブジェクトが受信するキューの名前を示す文字列です。

MessageListener listener;
listener = new MessageListener( onMessage );
mgr.SetMessageListener( "queue-name", listener );

♦ メッセージの非同期的受信 (C++ の場合)

QAMessageListener インターフェイスを実装するクラスを作成します。

class MyClass: public QAMessageListener {
   public:
   void onMessage( QAMessage * Msg);
};

onMessage メソッドを実装します。

QAMessageListener インターフェイスには onMessage という名前のメソッドがあります。キューにメッセージが着信するたびに、QAnywhere ライブラリはこのメソッドを呼び出します。そのとき、着信メッセージが唯一の引数として渡されます。

void MyClass::onMessage(QAMessage * msg) {
     // Process message.
}

メッセージリスナーを登録します。

my_listener = new MyClass();
mgr->setMessageListener( "queue-name", my_listener );

♦ メッセージの非同期的受信 (Java の場合)

メッセージハンドラーメソッドと例外ハンドラーメソッドを実装します。

class MyClass implements QAMessageListener {
  public void onMessage(QAMessage message) {
    // Process the message.
  }
  public void onException(
    QAException exception, QAMessage message) {
    // Handle the exception.
  }
}

メッセージハンドラーを登録します。

MyClass listener = new MyClass();
mgr.setMessageListener("queue-name", listener);

♦ メッセージの非同期的受信 (SQL の場合)

ml_qa_listener_queue という名前のストアドプロシージャーを作成します。queue はメッセージキューの名前です。

このプロシージャーは、指定されたキューにメッセージが登録されるたびに呼び出されます。

参照

DocCommentXchange で意見交換できます