messagelistentask.java

《j2ee开发全程实录》随书源码

package com.cownew.PIS.base.msgCenter.client;

import java.util.TimerTask;

import javax.jms.JMSException;
import javax.jms.TextMessage;

import com.cownew.PIS.framework.client.MainFrame;
import com.cownew.PIS.framework.client.RemoteServiceLocator;
import com.cownew.PIS.framework.common.msgMgr.IMessageService;
import com.cownew.PIS.ui.base.ExceptionHandler;
import com.cownew.ctk.ui.swing.MsgBox;

public class MessageListenTask extends TimerTask
{
	public void run()
	{
		IMessageService msgService = (IMessageService) RemoteServiceLocator
				.getRemoteService(IMessageService.class);
		TextMessage[] txtMsgs = msgService.receiveMessage();
		for(int i=0,n=txtMsgs.length;i<n;i++)
		{
			try
			{
				MsgBox.showInfo(MainFrame.getMainFrame(),txtMsgs[i].getText());
			} catch (JMSException e)
			{
				ExceptionHandler.handle(e);
			}
		}
	}

}