From cc9712442310d7fff03fe20feaefd7ddf1905bc0 Mon Sep 17 00:00:00 2001 From: Tobias Eidelpes Date: Mon, 17 May 2021 17:33:01 +0200 Subject: [PATCH] Declare queues correctly (3.1.1) --- .../src/main/java/dst/ass3/messaging/impl/QueueManager.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/ass3-messaging/src/main/java/dst/ass3/messaging/impl/QueueManager.java b/ass3-messaging/src/main/java/dst/ass3/messaging/impl/QueueManager.java index 5b54c6f..52777ec 100644 --- a/ass3-messaging/src/main/java/dst/ass3/messaging/impl/QueueManager.java +++ b/ass3-messaging/src/main/java/dst/ass3/messaging/impl/QueueManager.java @@ -36,6 +36,10 @@ public class QueueManager implements IQueueManager { channel.exchangeDeclare(Constants.QUEUE_AT_LINZ, "direct", true); channel.exchangeDeclare(Constants.QUEUE_DE_BERLIN, "direct", true); + viennaQueue = channel.queueDeclare(Constants.QUEUE_AT_VIENNA, false, false, false, null).getQueue(); + linzQueue = channel.queueDeclare(Constants.QUEUE_AT_LINZ, false, false, false, null).getQueue(); + berlinQueue = channel.queueDeclare(Constants.QUEUE_DE_BERLIN, false, false, false, null).getQueue(); + channel.queueBind(viennaQueue, Constants.QUEUE_AT_VIENNA, Constants.ROUTING_KEY_AT_VIENNA.toLowerCase()); channel.queueBind(linzQueue, Constants.QUEUE_AT_LINZ, Constants.ROUTING_KEY_AT_LINZ.toLowerCase()); channel.queueBind(berlinQueue, Constants.QUEUE_DE_BERLIN, Constants.ROUTING_KEY_DE_BERLIN.toLowerCase());