From 17fae78801321e0c7e0fe22cb8f4d313f98371d6 Mon Sep 17 00:00:00 2001 From: damage Date: Thu, 26 Sep 2024 09:21:01 +0200 Subject: [PATCH] seperate connections --- src/main/java/de/berlin/airport/artemis/Main.java | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) diff --git a/src/main/java/de/berlin/airport/artemis/Main.java b/src/main/java/de/berlin/airport/artemis/Main.java index 88a4396..3cdc215 100644 --- a/src/main/java/de/berlin/airport/artemis/Main.java +++ b/src/main/java/de/berlin/airport/artemis/Main.java @@ -46,14 +46,18 @@ public class Main { jmxBroker.connect(JMX_HOST, JMX_PORT, USERNAME, PASSWORD); // JMXQueue jmxQueue = jmxBroker.getQueueJMX(QUEUE); - Client amqpCLient = Client.create(); ConnectionOptions ampqConnectionOptions = new ConnectionOptions(); ampqConnectionOptions.user(USERNAME); ampqConnectionOptions.password(PASSWORD); - Connection amqpConnection = amqpCLient.connect(AMQP_HOST, AMQP_PORT, ampqConnectionOptions); - Receiver amqpReceiver = amqpConnection.openReceiver(QUEUE); - Sender amqpSender = amqpConnection.openSender(QUEUE); + Client amqpClientSender = Client.create(); + Connection amqpConnectionSender = amqpClientSender.connect(AMQP_HOST, AMQP_PORT, ampqConnectionOptions); + Sender amqpSender = amqpConnectionSender.openSender(QUEUE); + + Client amqpClientReceiver = Client.create(); + Connection amqpConnectionReceiver = amqpClientReceiver.connect(AMQP_HOST, AMQP_PORT, ampqConnectionOptions); + Receiver amqpReceiver = amqpConnectionReceiver.openReceiver(QUEUE); + amqpSender.send(Message.create("Hello baz")); Delivery amqpDelivery = amqpReceiver.receive(); System.out.println(amqpDelivery.message().body().toString()); @@ -154,7 +158,8 @@ public class Main { // System.in.read(); jmxBroker.disconnect(); - amqpConnection.close(); + amqpConnectionSender.close(); + amqpConnectionReceiver.close(); } public static void main(String[] args) {