Interstage Application Server J2EE ユーザーズガイド

21.2.8.4 グローバルトランザクションを使用したReceiverの作成

[グローバルトランザクションのReceiver]

public class ReceiverS {
  public static void main() {
      ...
      try {
          InitialContext initialContext = new InitialContext();                                       /* 1 */
          QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)
              initialContext.lookup("java:comp/env/jms/QueueConnectionFactory");                      /* 2 */
          Queue queue = (Queue)initialContext.lookup("java:comp/env/jms/Queue");                      /* 3 */
          javax.transaction.UserTransaction ut = 
              (javax.transaction.UserTransaction)initialContext.lookup("java:comp/UserTransaction");  /* 4 */
          QueueConnection queueConnection = queueConnectionFactory.createQueueConnection();           /* 5 */
          QueueSession queueSession = queueConnection.createQueueSession(true , 0);                   /* 6 */
          QueueReceiver queueReceiver = queueSession.createReceiver(queue);                           /* 7 */
          queueConnection.start();                                                                    /* 8 */
          ut.begin();                                                                                 /* 9 */
          Message message = queueReceiver.receive();                                                  /* 10 */
          ut.commit();                                                                                /* 11 */
          queueConnection.close();                                                                    /* 12 */
      } catch( Exception e ) {
          ...
      }
      ...
  }
}

　1. JNDIの開始コンテキストを構築する。
　2. QueueConnectionFactoryオブジェクトを取得する。（JNDI名が“QueueConnectionFactory”の場合）
　3. Queue オブジェクトを取得する。（JNDI名が“Queue”の場合）
　4. ユーザトランザクションオブジェクトを取得する。
　5. QueueConnectionを作成する。
　6. QueueSessionを作成する。
　7. QueueReceiverを作成する。
　8. 接続によるメッセージの配信を開始する。
　9. グローバルトランザクションを開始します。
　10. メッセージを受信する。
　11. グローバルトランザクションを完了します。
　12. QueueConnectionをクローズする。

　JNDIの開始コンテキスト構築時の環境プロパティの指定については、“J2EEアプリケーションクライアント”を参照してください。