nsq_async_rs::commands

Function mpublish_messages

Source 
pub async fn mpublish_messages<A: ToSocketAddrs + Display>(
    nsqd_addr: A,
    topic: &str,
    messages: Vec<Vec<u8>>,
) -> Result<()>
Expand description

批量向NSQ主题发布消息