package com.sy.IMF;

import com.caac.imf.api.IMFClient;
import com.sy.controller.AnalysisRoute;
import org.apache.log4j.Logger;

public class KAKO_Reader extends Thread{
    protected static final Logger logger = Logger.getLogger(KAKO_Reader.class);
    private IMFClient client;
    public static  boolean isrunning;

    public KAKO_Reader(IMFClient client) {
        this.client = client;
    }

    public void run() {

        try{
            isrunning =true;
            while(true) {
                if (IMF_Tesk.LOGIN_OK) synchronized (this) {
                    String message = this.client.getMSG();
                    if (message != null) {
                        logger.info(message);
                        AnalysisRoute route = new AnalysisRoute();
                        route.analysis(message);
                    }
                }
                else {
                    //logger.info("***");
                }

                try {
                    Thread.sleep(1000L);
                } catch (InterruptedException var3) {
                    var3.printStackTrace();

                }
            }

        }catch (Exception e){
            isrunning=false;
            logger.info("****************读取线程不在了****************");
        }
    }
}