Function amqpr::broadcast::broadcast_sink

pub fn broadcast_sink(
    exchange_name: String, 
    addr: SocketAddr, 
    user: String, 
    pass: String, 
    handle: Handle
) -> UnboundedSender<Bytes>