queuesend.java

基于JMS的消息,用包括界面代码,主要用初学都学习

package com.sjx.jms;

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

public class QueueSend {
	Context context = null;
	QueueConnectionFactory queueConnectionFactory = null;
	QueueConnection queueConnection = null;
	QueueSession queueSession = null;
	Queue queue = null;
	QueueSender queueSender = null;
	TextMessage message = null;
	
	public QueueSend(){  
		context = GetJini.getContext();
		queueConnectionFactory = GetJini.getQueueConnectionFactory(context);
		try{
			//获得JMS信息连接队列  
			queueConnection =  GetJini.getQueueConnection(queueConnectionFactory);  
			//产生队列Session，设置事务为false，自动应答消息接收  
			queueSession =queueConnection.createQueueSession(false,   Session.AUTO_ACKNOWLEDGE);  
			//获得默认内建在JMS里的队列之一：queue1  
			queue = (Queue) context.lookup("queue1");  
			//产生JMS队列发送器  
            queueSender =  queueSession.createSender(queue);  
            //发送数据到JMS  
            message = queueSession.createTextMessage();
            
		}catch(JMSException e){
			e.printStackTrace();
		}catch(NamingException e){
			e.printStackTrace();
		}
	}
	
	public void send(String string){
		try {
			message.setText(string);
			queueSender.send(message); 
		} catch (JMSException e) {
			e.printStackTrace();
		}
	}
	
	public void close(){
		GetJini.closeQueudSender(queueSender);
		GetJini.closeQueueSession(queueSession);
		GetJini.closeQueueConnection(queueConnection);
		GetJini.closeContext(context);
	}
	
	/*public static void main(String args[]){
		QueueSend q=new QueueSend();
		q.send("Hello");
		q.close();
	}*/
}