pub async fn notify(kevy: &mut ConnectionManager)
notify the delivery worker that new messages are queued