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