Function new_data_sender

pub fn new_data_sender(
    conn_pool: &Arc<Mutex<HashMap<String, Connection>>>,
    config: &BrokerData,
) -> Result<Queue, Box<dyn StdError>>

Create data channel sender queue.