topicsend.java

jboss的jms一个小程序

package com.hotct.jms;

import javax.jms.*;
import javax.naming.*;
import java.util.*;
public class TopicSend {
	public static void main(String[] args) throws Exception{
		Context ctx = getInitialContext();
		TopicConnectionFactory topicConnectionFactory =
			(TopicConnectionFactory)ctx.lookup("TopicConnectionFactory");
		Topic topic = (Topic)ctx.lookup("topic/testTopic");
		TopicConnection topicConnection = topicConnectionFactory.createTopicConnection();
		TopicSession topicSession = topicConnection.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);
		TopicPublisher topicPublisher = topicSession.createPublisher(topic);
		TextMessage message = topicSession.createTextMessage();
		for(int i=0; i<3;i++){
			message.setText("Message " + i + "from Topic");
			System.out.println("Publishing message:"+ message.getText());
			topicPublisher.publish(message);
		}
		
		topicPublisher.publish(topicSession.createMessage());
		
		if(topicConnection != null){
			topicPublisher.close();
			topicSession.close();
			topicConnection.close();
		}
	}
	private static Context getInitialContext() throws NamingException{
		Hashtable environment =  new Hashtable();
		environment.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
		environment.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");
		environment.put(Context.PROVIDER_URL, "jnp://localhost:1099");
		return new InitialContext(environment);
	}
}