queueexample1listener.java

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

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

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

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

	/* (non-Javadoc)
	 * @see javax.jms.MessageListener#onMessage(javax.jms.Message)
	 */
	public void onMessage(Message message) {
		if (message instanceof TextMessage) {
			TextMessage  msg = (TextMessage) message;
			try {
				System.out.println("Reading message: " + msg.getText());
			} catch (JMSException e) {
				System.out.println("Exception in onMessage(): " + e.toString());
			}
		} else {
			
		}
	}

}