| Interstage Application Server J2EE ユーザーズガイド |
目次
索引
![]()
|
| 第5部 JMS編 | > 第22章 JMSアプリケーションの開発 | > 22.2 作成方法 | > 22.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アプリケーションクライアント”を参照してください。
目次
索引
![]()
|