pub async fn get_listeners_from_context(
    ctx: &Context
) -> Result<EventDrivenMessagesRef>