pub fn subscribe_with_ids_and_headers<T, F, G>( topic: &str, queue_size: usize, on_message: F, on_connect: G, ) -> Result<Subscriber>where T: Message, F: Fn(T, &str) + Send + 'static, G: Fn(HashMap<String, String>) + Send + 'static,