package com.mvc.utils;


import com.mvc.entity.TPackLog2;
import com.mvc.model.TAireadModel;
import com.mvc.model.TServerReadModel;
import com.mvc.netty.FzBaowenModel;

import java.util.concurrent.ArrayBlockingQueue;

public class StoreBlockingQueue {
    public static ArrayBlockingQueue<FzBaowenModel> baoweoQueue=new ArrayBlockingQueue<FzBaowenModel>(10000);
    public static ArrayBlockingQueue<TPackLog2> logQueue=new ArrayBlockingQueue<TPackLog2>(10000);
    public static ArrayBlockingQueue<FzBaowenModel>  errorQueue=new ArrayBlockingQueue<FzBaowenModel>(10000);
    public static ArrayBlockingQueue<TAireadModel>  tAireadQueue=new ArrayBlockingQueue<TAireadModel>(10000);
    public static ArrayBlockingQueue<TAireadModel>  forwarderQueue= new ArrayBlockingQueue<>(1000);//数据转发队列(向各个水务局推送的队列)

    //系统审核队列(三四级免审,要自动推送到水利所) 2022-10-20 guozhao
    public static ArrayBlockingQueue<TAireadModel>  sysReviewQueue=new ArrayBlockingQueue<>(1000);

    //燃气表报警队列 2024-02-06 guozhao
    public static ArrayBlockingQueue<TServerReadModel>  gasAlarmQueue= new ArrayBlockingQueue<>(200);

    //服务侧免配置识别队列
    //public static ArrayBlockingQueue<WmInModel>  noConfigIdentQueue= new ArrayBlockingQueue<>(1000);
}
