package com.ld.igds.protocol.gps;
|
|
import com.ld.igds.util.SpringUtil;
|
import com.ld.io.api.IoMsgConsumer;
|
import com.ld.io.api.IoSession;
|
|
/**
|
* 接受到终端信息，然后调用解决接口进行解析
|
*
|
* @author:
|
* @description:
|
* @version:
|
* @data:
|
*
|
*/
|
public class MessageConsume implements IoMsgConsumer {
|
|
private AnalysisInvoker analysisInvoker;
|
|
@Override
|
public void consume(IoSession session, byte[] bytes) {
|
|
if (null == analysisInvoker) {
|
analysisInvoker = (AnalysisInvoker) SpringUtil
|
.getBean(AnalysisInvoker.BEAN_ID);
|
}
|
analysisInvoker.analysis(session,session.getAddress(), session.getPort(), bytes);
|
}
|
|
}
|
