package com.mvc.iot;

import com.mvc.iot.model.IotTempModel;
import com.mvc.iot.onenet.model.OneNetRootModel;
import com.mvc.model.TaskRemoteCfgModel;
import com.mvc.model.aep.AepRootModel;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * IOT平台处理相关队列
 */
public class IotStoreBlockingQueue {
    //物联网平台数据接收队列(数据队列,AiRead相关的) 2024-10-12 guozhao
    public static ArrayBlockingQueue<IotTempModel> iotDataQueue = new ArrayBlockingQueue<>(5000);

    //IOT 平台下行命令队列
    public static ArrayBlockingQueue<TaskRemoteCfgModel> iotCommandQueue =  new ArrayBlockingQueue<>(100);

    //移动OneNet 平台数据接收队列
    public static ArrayBlockingQueue<OneNetRootModel> oneDateCacheQueue = new ArrayBlockingQueue<>(500);

    //电信AEP 平台数据接收队列
    public static ArrayBlockingQueue<AepRootModel> aepCacheQueue =  new ArrayBlockingQueue<>(500);
}
