ptpsender.java

21天精通Java,这是一本英文书

package client;

import javax.naming.*;
import javax.jms.*;

public class PTPSender {

	private QueueConnection queueConnection; 
	private QueueSession queueSession;		
	private QueueSender queueSender;			
	private Queue queue;
	
	private static final String jndiFactory = "QueueConnectionFactory";
	private static String jndiQueue = "jms/jobQueue";
 
	public static void main(String[] args) {
	try {
 
		PTPSender sender = new PTPSender(jndiFactory, jndiQueue);

		sender.send(args[0]);

		sender.close(); 			
 
	} catch(Exception ex) {
		System.err.println("Exception in PTPSender: " + ex);
	}
} 

	public PTPSender(String jndiFactory, String jndiQueue) throws JMSException, NamingException {
		System.out.println(jndiQueue);
		Context context = new InitialContext(); 	
		QueueConnectionFactory queueFactory = (QueueConnectionFactory)context.lookup(jndiFactory);		
		queueConnection = queueFactory.createQueueConnection();
		queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); 
		queue = (Queue)context.lookup(jndiQueue);	 
		queueSender = queueSession.createSender(queue);
	}
	
	public void send(String msg) throws JMSException {
		TextMessage message = queueSession.createTextMessage(); 	
		message.setText(msg);
		message.setBooleanProperty("NewApplicant", true);
		queueSender.send(message);					
		}

	public void close() throws JMSException {
		//Send a non-text control message indicating end of messages
		//queueSender.send(queueSession.createMessage());

		queueSender.close();
		queueSession.close();
		queueConnection.close();
	}
}