make sure to bind the completed queue

NCEAS · Jan 30, 2024 · 6f2ff7f · 6f2ff7f
1 parent 6f57094
commit 6f2ff7f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/edu/ucsb/nceas/mdqengine/Worker.java b/src/main/java/edu/ucsb/nceas/mdqengine/Worker.java
@@ -519,6 +519,7 @@ public void setupQueues() throws IOException, TimeoutException {
 
         try {
             RabbitMQchannel.queueDeclare(COMPLETED_QUEUE_NAME, durable, false, false, null);
+            RabbitMQchannel.queueBind(COMPLETED_QUEUE_NAME, EXCHANGE_NAME, COMPLETED_ROUTING_KEY);
             log.info("Connected to RabbitMQ queue " + COMPLETED_QUEUE_NAME);
         } catch (Exception e) {
             log.error("Error connecting to RabbitMQ queue " + COMPLETED_QUEUE_NAME);