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());