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);
	}

}