Interstage Application Server J2EE ユーザーズガイド |
目次 索引 |
第5部 JMS編 | > 第21章 JMSアプリケーションの開発 | > 21.2 作成方法 | > 21.2.1 Publish/Subscribeメッセージングモデル |
Subscriberはイベントチャネルにメッセージを要求します。Subscriberがイベントチャネルにメッセージを要求する手続き例と処理の流れを以下に説明します。
[Subscriber]
public class SubscriberS { 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 */ TopicConnection topicConnection = topicConnectionFactory.createTopicConnection(); /* 4 */ TopicSession topicSession = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); /* 5 */ TopicSubscriber topicSubscriber = topicSession.createSubscriber(topic); /* 6 */ topicConnection.start(); /* 7 */ Message message = topicSubscriber.receive(); /* 8 */ topicConnection.close(); /* 9 */ } catch( Exception e ) { ... } ... } } |
1. JNDIの開始コンテキストを構築する。
2. TopicConnectionFactoryオブジェクトを取得する。(JNDI名が“TopicConnectionFactory”の場合)
3. Topic オブジェクトを取得する。(JNDI名が“Topic”の場合)
4. TopicConnectionを作成する。
5. TopicSessionを作成する。
6. TopicSubscriberを作成する。
7. 接続によるメッセージの配信を開始する。
8. メッセージを受信する。
9. TopicConnectionをクローズする。
JNDIの開始コンテキスト構築時の環境プロパティの指定については、“J2EEアプリケーションクライアント”を参照してください。
目次 索引 |