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.