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

第6部 JMS編> 第24章 JMSアプリケーションの開発> 24.2 作成方法

24.2.10 キューブラウザ機能

 アプリケーションでは、キューに蓄積されているメッセージを参照するためにBrowserを作成します。その後、順にメッセージを取り出すことができ、キューの内容をブラウジングできます。以下にキューブラウザの手続き例と処理の流れを示します。

[Browser]

import javax.jms.*;
import javax.naming.*;

public class Browser {
  public static void main( String[] args ) {
    Connection connection = null;
    ...
    try {
        java.util.Hashtable env = new java.util.Hashtable( );
        env.put ( javax.naming.Context.INITIAL_CONTEXT_FACTORY ,
                 "com.fujitsu.interstage.j2ee.jndi.InitialContextFactoryForClient" );
        InitialContext initialContext = new InitialContext(env);                     /* 1 */
        ConnectionFactory connectionFactory = (ConnectionFactory)
            initialContext.lookup("java:comp/env/jms/ConnectionFactory");            /* 2 */
        Queue queue = (Queue)initialContext.lookup("java:comp/env/jms/Queue");       /* 3 */
        connection = connectionFactory.createConnection();                           /* 4 */
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); /* 5 */
        QueueBrowser queueBrowser = session.createBrowser(queue);                    /* 6 */
        connection.start();                                                          /* 7 */
        java.util.Enumeration e = queueBrowser.getEnumeration();                     /* 8 */
        Message message;
        while ( e.hasMoreElements() ) {
            message = (Message)e.nextElement();                                      /* 9 */
            ...
        }
        queueBrowser.close();                                                        /* 10 */
    } catch( Exception e ) {
        ... 
    }
    finally {
        if( null != connection ) {
            try {
                connection.close();                                                  /* 11 */
            }
            catch( Exception e ) {
                ...
            }
        }
    }
  }
}
  1. JNDIの開始コンテキストを構築します。
  2. ConnectionFactoryオブジェクトを取得します(JNDI名が“ConnectionFactory”の場合)。
  3. Queue オブジェクトを取得します(JNDI名が“Queue”の場合)。
  4. Connectionを作成します。
  5. Sessionを作成します。
  6. QueueBrowserを作成します。
  7. 接続によるメッセージの配信を開始します。
  8. ブラウジングを開始します。
  9. 1メッセージを取得します。
  10. QueueBrowserをクローズします。
  11. Connectionをクローズします。


 JNDIの開始コンテキスト構築時の環境プロパティの指定については、“J2EEアプリケーションクライアント”を参照してください。
 1つのチャネルに対し、複数のキューブラウザを使用することはできません。


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

Copyright 2008 FUJITSU LIMITED