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 */
TopicConnection topicConnection = topicConnectionFactory.createTopicConnection(); /* 4 */
TopicSession topicSession = topicConnection.createTopicSession(true, 0); /* 5 */
TopicPublisher topicPublisher = topicSession.createPublisher(topic); /* 6 */
topicPublisher.publish(Message); /* 7 */
topicSession.commit(); /* 8 */
topicConnection.close(); /* 9 */
} catch( Exception e ) {
...
}
...
}
} |