may need to load metadata to resolve the queue

This commit is contained in:
Wez Furlong
2023-02-19 16:53:42 -07:00
parent 9149063b57
commit 6ebf6762ce
+4
View File
@@ -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;