Declare chimp job queue when creating consumer

DiamondLightSource · Aug 9, 2023 · d14b171 · d14b171
1 parent 6dcf0d1
commit d14b171
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/chimp_chomp/src/jobs.rs b/chimp_chomp/src/jobs.rs
@@ -5,7 +5,7 @@ use crate::{
 use chimp_protocol::{Circle, Job, Response};
 use futures::StreamExt;
 use lapin::{
-    options::{BasicAckOptions, BasicConsumeOptions, BasicPublishOptions},
+    options::{BasicAckOptions, BasicConsumeOptions, BasicPublishOptions, QueueDeclareOptions},
     types::FieldTable,
     BasicProperties, Channel, Connection, Consumer,
 };
@@ -33,6 +33,13 @@ pub async fn setup_job_consumer(
 ) -> Result<Consumer, lapin::Error> {
     let worker_id = Uuid::new_v4();
     let worker_tag = format!("chimp_chomp_{worker_id}");
+    rabbitmq_channel
+        .queue_declare(
+            channel.as_ref(),
+            QueueDeclareOptions::default(),
+            FieldTable::default(),
+        )
+        .await?;
     rabbitmq_channel
         .basic_consume(
             channel.as_ref(),