jmslistener.java

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

/**
 * JmsListener.java Created on 2003-12-7
 *
 */
package com.liuyang.xmessenger.impl;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;

import com.liuyang.xmessenger.Listener;
import com.liuyang.xmessenger.device.OutputDevice;

/**
 * @author liuyang
 *
 */
public class JmsListener extends Listener implements MessageListener{
	
	public JmsListener(TopicSession session,Topic topic,TopicConnection coon){
		if(session!=null)try {
			TopicSubscriber subscriber =session.createSubscriber(topic);
			subscriber.setMessageListener(this);
			coon.start();
		} catch (JMSException e) {
			e.printStackTrace();
		}
	}
	/* (non-Javadoc)
	 * @see com.liuyang.chatroom.Listener#onMessage()
	 */
	public void onMessage() {
		//System.out.println("有消息到来！");
		if((message instanceof TextMessage)&&(screen!=null)){
			TextMessage msg = (TextMessage) message;
			try {
				screen.scroll(msg.getText());
			} catch (JMSException e) {
				e.printStackTrace();
			}		
		}
		//System.out.println(message);
	}
	private Message message = null;
	/* (non-Javadoc)
	 * @see javax.jms.MessageListener#onMessage(javax.jms.Message)
	 */
	public void onMessage(Message msg) {
		message = msg ; 
		this.onMessage();
	}
	private OutputDevice screen = null;
	/* (non-Javadoc)
	 * @see com.liuyang.chatroom.Listener#getChatScreen()
	 */
	public OutputDevice getOutputDevice() {
		return screen;
	}
	/* (non-Javadoc)
	 * @see com.liuyang.chatroom.Listener#setChatScreen()
	 */
	public void setOutputDevice(OutputDevice charscreen) {
		screen = charscreen;
	}
	
}