sylvia_iot_data::libs::mq::coremgr

Function new

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

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