From 1124cb0c5e12556560edf84a4b41bd4f8352a973 Mon Sep 17 00:00:00 2001
From: Abdelrahman Elsalh <abdof1723@gmail.com>
Date: Sun, 19 May 2024 17:14:45 +0300
Subject: [PATCH] set connection factory rabbitmq

---
 .../java/com/workup/jobs/ControllerMQListener.java     | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/services/jobs/src/main/java/com/workup/jobs/ControllerMQListener.java b/services/jobs/src/main/java/com/workup/jobs/ControllerMQListener.java
index b1a2230c..6d539663 100644
--- a/services/jobs/src/main/java/com/workup/jobs/ControllerMQListener.java
+++ b/services/jobs/src/main/java/com/workup/jobs/ControllerMQListener.java
@@ -15,6 +15,7 @@
 import org.springframework.amqp.rabbit.annotation.RabbitHandler;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.ApplicationContext;
@@ -28,6 +29,7 @@ public class ControllerMQListener {
   @Autowired public ThreadPoolTaskExecutor taskExecutor;
   @Autowired private ApplicationContext context;
   @Autowired private RabbitListenerEndpointRegistry registry;
+  @Autowired private RabbitTemplate rabbitTemplate;
 
   private static final Logger logger = LogManager.getLogger(ControllerMQListener.class);
 
@@ -122,8 +124,12 @@ public void receive(SetMessageQueueRequest in) throws Exception {
       connectionFactory.setPort(in.getPort());
       connectionFactory.setUsername("guest");
       connectionFactory.setPassword("guest");
-
-      System.out.println("Message queue set to: " + in.getHost() + ":" + in.getPort());
+      rabbitTemplate.setConnectionFactory(connectionFactory);
+      System.out.println(
+          "Message queue set to: "
+              + rabbitTemplate.getConnectionFactory().getHost()
+              + ":"
+              + rabbitTemplate.getConnectionFactory().getPort());
     } catch (Exception e) {
       System.out.println(e.getMessage());
       e.printStackTrace();