topicexample1publisher.java

精通Jboss——Ejb和Web Services开发精解的随书源代码

/**
 * Created on 2003-9-14
 */
package com.liuyang.jboss.message.jms.topic;

import java.util.Hashtable;

import javax.jms.DeliveryMode;
import javax.jms.JMSException;
import javax.jms.Message;
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.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

/**
 * @author
 * <a href="mailto:[e-mail]">刘洋</a>
 */
public class TopicExample1Publisher {

	public static void main(String[] args) throws Exception {
		TopicExample1Publisher publisher = new TopicExample1Publisher();
		publisher.connect();
		TextMessage textmsg= publisher.session.createTextMessage();
		textmsg.setText("TopicExample1Publisher"+"发送了一次消息,"+"时间戳："+System.currentTimeMillis());	
		
		publisher.Publish(textmsg);
		publisher.disconnect();
	}
	public TopicSession session;
	private Topic topic;
	private TopicConnection conn;
	private TopicPublisher publisher ;
	private Context iniCtx;		
	public void connect() throws NamingException, JMSException{
		Hashtable env = new Hashtable();
		env.put(Context.INITIAL_CONTEXT_FACTORY,"org.jnp.interfaces.NamingContextFactory");
		env.put(Context.PROVIDER_URL,"localhost");
		Context iniCtx = new InitialContext(env);		
		Object tmp = iniCtx.lookup("ConnectionFactory");
		TopicConnectionFactory tcf = (TopicConnectionFactory) tmp;
		topic = (Topic)iniCtx.lookup("topic/MemoryReporter");
		conn = tcf.createTopicConnection();
		session = conn.createTopicSession(false,TopicSession.AUTO_ACKNOWLEDGE);
		conn.start();
		publisher = session.createPublisher(topic);
	}
	public void disconnect() throws Exception{
		publisher.close();
		conn.stop();
		session.close();
		conn.close();
	}

	public void Publish(Message msg) throws JMSException{
		publisher.publish(msg,DeliveryMode.NON_PERSISTENT,7,3000);
	}
}