sylvia_iot_broker::libs::mq::control

Function new

Source
pub fn new(
    conn_pool: Arc<Mutex<HashMap<String, Connection>>>,
    host_uri: &Url,
    prefetch: Option<u16>,
    func_name: &str,
    is_recv: bool,
    handler: Arc<dyn EventHandler>,
    msg_handler: Arc<dyn MessageHandler>,
) -> Result<Queue, String>
Expand description

To create a broadcast queue for a function to send or receive control messages.