pub async fn fetch_one_message<T: for<'de> Deserialize<'de>>( query: &str, connection: &Pool<Postgres>, ) -> Result<Option<Message<T>>, PgmqError>