From 6ebf6762ced7873dcfe6eb91bb4599fe62613a58 Mon Sep 17 00:00:00 2001 From: Wez Furlong Date: Sun, 19 Feb 2023 16:53:42 -0700 Subject: [PATCH] may need to load metadata to resolve the queue --- crates/kumod/src/dest_site.rs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/crates/kumod/src/dest_site.rs b/crates/kumod/src/dest_site.rs index 3e49c4f2..ed1f2cc9 100644 --- a/crates/kumod/src/dest_site.rs +++ b/crates/kumod/src/dest_site.rs @@ -507,6 +507,10 @@ impl Dispatcher { async fn requeue_message(msg: Message, increment_attempts: bool) -> anyhow::Result<()> { let mut queue_manager = QueueManager::get().await; + if !msg.is_meta_loaded() { + let meta_spool = SpoolManager::get_named("meta").await?; + msg.load_meta(&**meta_spool.lock().await).await?; + } let queue_name = msg.get_queue_name()?; let queue = queue_manager.resolve(&queue_name).await?; let mut queue = queue.lock().await;