pub fn subscribe_with_ids<T, F>( topic: &str, queue_size: usize, callback: F, ) -> Result<Subscriber>where T: Message, F: Fn(T, &str) + Send + 'static,