topicmessagetest.java

来自「这个是学习EJB的好例子,里面有许多关于EJB Bean的」· Java 代码 · 共 50 行

package com.cws.ejb.message;

import java.util.Properties;

import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;
import javax.naming.InitialContext;

public class TopicMessageTest {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		TopicConnection conn = null;
		TopicPublisher publisher = null;
		TopicSession session = null;
		Topic topic = null;

		try {
			Properties props = new Properties();
			props.setProperty("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
			props.setProperty("java.naming.provider.url", "localhost:1099");
			props.setProperty("java.naming.factory.url.pkgs", "org.jboss.naming");
			InitialContext ctx = new InitialContext(props);
			
			TopicConnectionFactory factory = (TopicConnectionFactory) ctx.lookup("ConnectionFactory");
			conn = factory.createTopicConnection();			
			session = conn.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);
			topic = (Topic) ctx.lookup("topic/cwsTopic");
			
			TextMessage msg = session.createTextMessage("这是我的第一个主题式消息驱动Bean");
			publisher = session.createPublisher(topic);
			publisher.publish(msg);
			session.close();
			
		}
		catch (Exception e) {
			System.out.println(e.getMessage());
		}	

	}

}