Function new

pub fn new(
    model: Arc<dyn Model>,
    mq_conns: &mut HashMap<String, Connection>,
    config: &DataData,
) -> Result<Queue, Box<dyn StdError>>

Create a receive queue to receive data from broker.data queue.