package com.temobi.epg.publisher.bo;

import javax.jms.ExceptionListener;
import javax.jms.JMSException;

import com.temobi.epg.publisher.initor.Initor;
import common.log.proxy.JLogger;
import common.log.proxy.LoggerFactory;

/**
 * JMS異常監聽器
 * @author lixu
 *
 */
public class JMSExceptionListener implements ExceptionListener {
	//log
	private static final JLogger log = LoggerFactory.getLogger(JMSExceptionListener.class);
	
	public void onException(JMSException je) {
		// TODO Auto-generated method stub
		log.error("mq occur error,now ready reconnect...");
		Initor.getInstance().closeEpgSubscriber();
		Initor.getInstance().startEpgSubscriber();	
	}

}