queuereceive.java

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

package com.sjx.jms;

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

public class QueueReceive {
	Context context = null;
	QueueConnectionFactory queueConnectionFactory = null;
	QueueConnection queueConnection = null;
	QueueSession queueSession = null;
	QueueReceiver queueReceiver = null;
	Queue queue = null;
	Message message = null;
	
	public QueueReceive(){
	try {
		context = GetJini.getContext();
		queueConnectionFactory = GetJini.getQueueConnectionFactory(context);
		queueConnection = queueConnectionFactory.createQueueConnection();
		queueConnection.start(); 
	    queueSession =queueConnection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);  
    	queue = (Queue)context.lookup("queue1"); 
    	queueReceiver = queueSession.createReceiver(queue);	
    	
		} catch (JMSException e) {
			e.printStackTrace();
		} catch (NamingException e) {
			e.printStackTrace();
		}
	}
	
	public String receive(){		
		String messageText = null;  
        try {        	 
        	Message message = queueReceiver.receive();
			if (message instanceof TextMessage)  
			    messageText = ((TextMessage) message).getText();
			System.out.println(messageText);  
		} catch (JMSException e) {
			e.printStackTrace();
		} 
		return messageText;
	}
	
	public void close(){
		GetJini.closeQueueReceive(queueReceiver);
		GetJini.closeQueueSession(queueSession);
		GetJini.closeQueueConnection(queueConnection);
		GetJini.closeContext(context);
	}
	
	/*public static void main(String args[]){
		QueueReceive q = new QueueReceive();
		q.receive();
		q.close();
	}*/
	
}