sylvia_iot_broker::libs::mq::data

Function new

Source
pub fn new(
    conn_pool: &Arc<Mutex<HashMap<String, Connection>>>,
    host_uri: &Url,
    persistent: bool,
    handler: Arc<dyn EventHandler>,
) -> Result<Queue, String>
Expand description

To create a reliable unicast queue to send data messages.