zenon/distributed-systems-technologies
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Declare queues correctly (3.1.1)

Browse Source
This commit is contained in:
Tobias Eidelpes 2021-05-17 17:33:01 +02:00
parent 928902fe0b
commit cc97124423
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ass3-messaging/src/main/java/dst/ass3/messaging/impl/QueueManager.java
View File

@ -36,6 +36,10 @@ public class QueueManager implements IQueueManager {
channel.exchangeDeclare(Constants.QUEUE_AT_LINZ, "direct", true); channel.exchangeDeclare(Constants.QUEUE_AT_LINZ, "direct", true);
channel.exchangeDeclare(Constants.QUEUE_DE_BERLIN, "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(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(linzQueue, Constants.QUEUE_AT_LINZ, Constants.ROUTING_KEY_AT_LINZ.toLowerCase());
channel.queueBind(berlinQueue, Constants.QUEUE_DE_BERLIN, Constants.ROUTING_KEY_DE_BERLIN.toLowerCase()); channel.queueBind(berlinQueue, Constants.QUEUE_DE_BERLIN, Constants.ROUTING_KEY_DE_BERLIN.toLowerCase());