Interstage Application Server J2EE ユーザーズガイド
目次 索引 前ページ次ページ

第5部 JMS編> 第21章 JMSアプリケーションの開発> 21.2 作成方法> 21.2.8 グローバルトランザクション

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

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

public class Publisher {
  public static void main() {
      ...
      try {
          InitialContext initialContext = new InitialContext();                                       /* 1 */
          TopicConnectionFactory topicConnectionFactory = (TopicConnectionFactory)
              initialContext.lookup("java:comp/env/jms/TopicConnectionFactory");                      /* 2 */
          Topic topic = (Topic)initialContext.lookup("java:comp/env/jms/Topic");                      /* 3 */
          javax.transaction.UserTransaction ut = 
              (javax.transaction.UserTransaction)initialContext.lookup("java:comp/UserTransaction");  /* 4 */
          TopicConnection topicConnection = topicConnectionFactory.createTopicConnection();           /* 5 */
          TopicSession topicSession = topicConnection.createTopicSession(true , 0);                   /* 6 */
          TopicPublisher topicPublisher = topicSession.createPublisher(topic);                        /* 7 */
          ut.begin();                                                                                 /* 8 */
          topicPublisher.publish(Message);                                                            /* 9 */
          ut.commit();                                                                                /* 10 */
          topicConnection.close();                                                                    /* 11 */
      } catch( Exception e ) {
          ...
      }
      ...
  }
}

 1. JNDIの開始コンテキストを構築する。
 2. TopicConnectionFactoryオブジェクトを取得する。(JNDI名が“TopicConnectionFactory”の場合)
 3. Topic オブジェクトを取得する。(JNDI名が“Topic”の場合)
 4. ユーザトランザクションオブジェクトを取得する。
 5. TopicConnectionを作成する。
 6. TopicSessionを作成する。
 7. TopicPublisherを作成する。
 8. グローバルトランザクションを開始します。
 9. メッセージを送信する。
 10. グローバルトランザクションを完了します。
 11. TopicConnectionをクローズする。


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


目次 索引 前ページ次ページ

All Rights Reserved, Copyright(C) 富士通株式会社 2005