sylvia_iot_data::libs::mq::broker

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 broker.data queue.