queueexample1.java

精通Jboss——Ejb和Web Services开发精解的随书源代码

/**
 * Created on 2003-9-13
 */
package com.liuyang.jboss.message.jms.queue;

import javax.jms.Message;
import javax.jms.TextMessage;

/**
 * @author
 * <a href="mailto:[e-mail]">刘洋</a>
 */
public class QueueExample1 {

	public static void main(String[] args) throws Exception {

		QueueExample1Sender sender = new QueueExample1Sender();
		sender.connect();
		QueueExample1Receiver receiver = new QueueExample1Receiver();
		receiver.connect();
				
		TextMessage textmsg = sender.session.createTextMessage();
		textmsg.setText("hello");
		sender.send(textmsg);
				
		Message msg = receiver.receive();
		if(msg instanceof TextMessage){
			System.out.println(((TextMessage)msg).getText());
		}else{
			System.out.println("no text");
		}
		receiver.disconnect();
		sender.disconnect();
	}
}