queuereceive.java

jboss的jms一个小程序

package com.hotct.jms;


import java.io.*;
import java.util.*;
import javax.transaction.*;
import javax.naming.*;
import javax.jms.Queue;
import javax.jms.*;

public class QueueReceive {
	public static void main(String[] args) throws Exception{
		//创建用于JNDI查询的Context
		Context ctx = getInitialContext();

		/**
		 * 获取QueueConnectionFactory
		 * ConnectionFactory为JBoss中已有的JNDI名字
		 */
		QueueConnectionFactory qconFactory =
			(QueueConnectionFactory)ctx.lookup("/ConnectionFactory");
		
		//获取Queue
		Queue queue = (Queue)ctx.lookup("/queue/testQueue");
		
		//从QueueConnectionFactory中创建QueueConnection
		QueueConnection qcon = qconFactory.createQueueConnection();
		
		/**
		 * 从QueueConnection中 创建QueueSession
		 * 第一个参数为 是否为Transacted，如果是接受后的消息会自动确认，这时忽略第二个参数，本例中虽然为false，
		 * 但是第二个参数还是指点了自动确认的方式
		 */
		QueueSession qsession = 
			qcon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
		
		//从QueueSession中创建QueueReceiver
		QueueReceiver qreceiver = qsession.createReceiver(queue);
		
		//准备接受消息
		qcon.start();
		while(true){
			Message m = qreceiver.receive();
			if(m instanceof TextMessage){
				//得到消息中的内容
				TextMessage message = (TextMessage)m;
				System.out.println("Reading message:" + message.getText());
			}
			else{
				break;
			}
		}
		//关闭消息
		qreceiver.close();
		qsession.close();
		qcon.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);
	}

}