diff --git a/src/main/java/edu/ucsb/nceas/mdqengine/Worker.java b/src/main/java/edu/ucsb/nceas/mdqengine/Worker.java index 3eb6d57b..471c8dd8 100644 --- a/src/main/java/edu/ucsb/nceas/mdqengine/Worker.java +++ b/src/main/java/edu/ucsb/nceas/mdqengine/Worker.java @@ -519,7 +519,6 @@ 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);