p2preceiver.java

jms队列通信接收端代码

package temp;

import java.util.Properties;

import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueReceiver;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;

import javax.naming.InitialContext;

import java.util.Hashtable;

/**
 * This class demonstrates a simple receiver in a point-to-point
 * JMS application.
 * @author dwhuang
 */
public class p2pReceiver
{
	public static void main(String[] args)
	{
		try
		{
			System.out.println("p2pReceiver started");
			//手工配置JNDI
			Properties props = new Properties();
			props.put("java.naming.factory.initial","org.jnp.interfaces.NamingContextFactory");
			props.put("java.naming.provider.url","192.168.100.34:1099");
			props.put("java.naming.factory.url.pkgs","org.jboss.naming:org.jnp.interfaces");
			InitialContext ic = new InitialContext(props);
			
			//queue/testQueue必须在$JBOSS_HOME/server/default/deploy/\jbossmq-destinations-service.xml文件中定义
			String queueName = "queue/testQueue";
			//查找连接工厂
			QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)ic.lookup("ConnectionFactory");
			//查找目的地
			Queue queue = (Queue)ic.lookup(queueName);
			
			//建立连接
			QueueConnection queueConnection = queueConnectionFactory.createQueueConnection();
			//建立会话
			QueueSession queueSession = queueConnection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
			//建立消息接收者
			QueueReceiver queueReceiver = queueSession.createReceiver(queue);
			
			//开启连接
			queueConnection.start();
			while(true)
			{
				/** 等待队列1 millisecond. if no message is received