package com.mvc.iot;

import com.mvc.iot.aep.AepDataHandler;
import com.mvc.iot.onenet.IoTPulsarConsume;
import com.mvc.iot.onenet.OnetDateHandler;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;

@Component
public class IotThreadManager {
    public static void initIotThread(ApplicationContext ac){
        //IOT平台命令处理线程
        new Thread(ac.getBean(IotCommandHandler.class)).start();

        //IOT平台数据处理线程(设备数据,对应AiRead相关的,将OneNet和AEP数据统一转换后的数据)
        //new Thread(ac.getBean(IoTDataHandler.class)).start();

        //OneNet平台数据处理线程
        //new Thread(ac.getBean(OnetDateHandler.class)).start();

        //OneNet数据接收线程
        //new Thread(ac.getBean(IoTPulsarConsume.class)).start();

        //AEP 平台数据处理线程
        //new Thread(ac.getBean(AepDataHandler.class)).start();

        //AEP-MQ数据接收线程
        //new Thread(ac.getBean(AepMqListener.class)).start();
    }
}
