Interstage Application Server J2EE ユーザーズガイド |
目次 索引 |
第5部 JMS編 | > 第21章 JMSアプリケーションの開発 | > 21.2 作成方法 |
アプリケーションでは、キューに蓄積されているメッセージを参照するためにBrowserを作成します。その後、順にメッセージを取り出すことができ、キューの内容をブラウジングできます。以下にキューブラウザの手続き例と処理の流れを示します。
[Browser]
public class Browser { 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 */ QueueConnection queueConnection = queueConnectionFactory.createQueueConnection(); /* 4 */ QueueSession queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); /* 5 */ QueueBrowser queueBrowser = queueSession.createBrowser(queue); /* 6 */ queueConnection.start(); /* 7 */ java.util.Enumeration e = qBrowser.getEnumeration(); /* 8 */ Message message; while ( e.hasMoreElements() ) { message = e.nextElement(); /* 9 */ ... } queueBrowser.close(); /* 10 */ queueConnection.close(); /* 11 */ } catch( Exception e ) { ... } ... } } |
1. JNDIの開始コンテキストを構築する。
2. QueueConnectionFactoryオブジェクトを取得する。(JNDI名が“QueueConnectionFactory”の場合)
3. Queue オブジェクトを取得する。(JNDI名が“Queue”の場合)
4. QueueConnectionを作成する。
5. QueueSessionを作成する。
6. QueueBrowserを作成する。
7. 接続によるメッセージの配信を開始する。
8. ブラウジングを開始する。
9. 1メッセージを取得する。
10. QueueBrowserをクローズする。
11. QueueConnectionをクローズする。
JNDIの開始コンテキスト構築時の環境プロパティの指定については、“J2EEアプリケーションクライアント”を参照してください。
1つのチャネルに対し、複数のキューブラウザを使用することはできません。
目次 索引 |