msgtestcase.java

《j2ee开发全程实录》随书源码

package com.cownew.PIS.base.msgCenter.client;

import java.util.Properties;

import javax.jms.DeliveryMode;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import com.cownew.PIS.framework.client.PISClientTestCase;
import com.cownew.PIS.framework.common.msgMgr.MessageException;
import com.cownew.PIS.framework.server.helper.ServerConfig;
import com.cownew.PIS.framework.server.msgMgr.MessageServer;
import com.cownew.ctk.common.ExceptionUtils;

public class MsgTestCase extends PISClientTestCase
{
	public void testSend()
	{
		Properties properties = new Properties();
		ServerConfig srvConfig = ServerConfig.getInstance();
		properties.put(Context.INITIAL_CONTEXT_FACTORY, srvConfig
				.getJMSContextFactory());
		properties.put(Context.PROVIDER_URL, srvConfig.getJMSUrl());
		Queue queue;
		QueueSession queueSession;
		try
		{
			Context context = new InitialContext(properties);
			// 获得JMS Topic连接队列工厂
			QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory) context
					.lookup(srvConfig.getJMSConnectionFactory());

			try
			{
				QueueConnection queueConnection = queueConnectionFactory
						.createQueueConnection();
				
				queueConnection.setClientID("abc");
				queueConnection.start();
				queue = (Queue) context
						.lookup(srvConfig.getJMSJndiName());
				queueSession = queueConnection.createQueueSession(false,
						Session.AUTO_ACKNOWLEDGE);
				
			} catch (JMSException e)
			{
				throw new MessageException(
						MessageException.MessageInitException,e);
			}

		} catch (NamingException e)
		{
			throw ExceptionUtils.toRuntimeException(e);
		}
		
		try
		{
			QueueSender queueSender = queueSession.createSender(queue);
			queueSender.setDeliveryMode(DeliveryMode.PERSISTENT);
			TextMessage txtMsg = queueSession.createTextMessage();
			txtMsg.setText("asdfasdf");
			queueSender.send(txtMsg);
		} catch (JMSException e)
		{
			throw new MessageException(MessageException.MessageSendException);
		}
	}
	
	public static void main(String[] args)
	{
		new MsgTestCase().testSend();
		TextMessage[] msgs = new MessageServer().receiveMessage("892E9423-C10D-E605-D4EF-EABA871FFB9D");
		System.out.println(msgs.length);
	}

}