//package com.ld.igds.protocol.iot.mq;
//
//import com.ld.igds.protocol.iot.analysis.AnalysisService;
//import com.ld.io.api.IoSession;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import java.util.concurrent.CountDownLatch;
//
///**
// * 报文接受到后处理
// */
//@Slf4j
//public class IotReceiverServer {
//
//    private CountDownLatch latch;
//
//    @Autowired
//    public IotReceiverServer(CountDownLatch latch) {
//        this.latch = latch;
//    }
//
//    @Autowired
//    private AnalysisService analysisService;
//
//
//
//    public void onMessage(String message) {
//    	message = message.replaceAll("\"", "");
//        log.info("-------获取队列信息---" + message);
//        try {
//            String[] attr = message.split("_");
//            String sessionKey = attr[0];
//            String msg = attr[1];
//             analysisService.analysis(sessionKey, msg);
//        } catch (Exception e) {
//            latch.countDown();
//            log.error("[IOT--消息队列数据失败，失败信息:{}]", e.getMessage(),e);
//        }
//        latch.countDown();
//    }
//    public void onLoginMessage(String sessionKey) {
//        log.info("onLoginMessage:" + sessionKey);
//    }
//
//}