From 23ebff12fb63b4169989e3a67f81e765f45ddd4e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?scnoh=28=EB=85=B8=EC=8A=B9=EC=B2=A0=29?=
 <stc9606@palnet.co.kr>
Date: Thu, 25 Aug 2022 11:15:13 +0900
Subject: [PATCH] =?UTF-8?q?meesage=20connection=20=EC=84=A4=EC=A0=95=20?=
 =?UTF-8?q?=EB=B3=80=EA=B2=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/palnet/biz/config/MessageConfig.java  | 24 +++++++++----------
 .../biz/message/consumer/MessageConsumer.java |  2 ++
 2 files changed, 14 insertions(+), 12 deletions(-)

diff --git a/src/main/java/com/palnet/biz/config/MessageConfig.java b/src/main/java/com/palnet/biz/config/MessageConfig.java
index 6d6a17c..026e5bb 100644
--- a/src/main/java/com/palnet/biz/config/MessageConfig.java
+++ b/src/main/java/com/palnet/biz/config/MessageConfig.java
@@ -22,17 +22,17 @@ public class MessageConfig {
         this.env = env;
     }
 
-    @Bean
-    public CachingConnectionFactory cachingConnectionFactory() {
-        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
-
-        connectionFactory.setHost(env.getProperty("spring.rabbitmq.host"));
-        connectionFactory.setPort(Integer.parseInt(env.getProperty("spring.rabbitmq.port")));
-        connectionFactory.setUsername(env.getProperty("spring.rabbitmq.username"));
-        connectionFactory.setPassword(env.getProperty("spring.rabbitmq.password"));
-
-        return connectionFactory;
-    }
+//    @Bean
+//    public CachingConnectionFactory cachingConnectionFactory() {
+//        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
+//
+//        connectionFactory.setHost(env.getProperty("spring.rabbitmq.host"));
+//        connectionFactory.setPort(Integer.parseInt(env.getProperty("spring.rabbitmq.port")));
+//        connectionFactory.setUsername(env.getProperty("spring.rabbitmq.username"));
+//        connectionFactory.setPassword(env.getProperty("spring.rabbitmq.password"));
+//
+//        return connectionFactory;
+//    }
 
     @Bean
     public Jackson2JsonMessageConverter converter() {
@@ -74,7 +74,7 @@ public class MessageConfig {
     }
 
     @Bean
-    public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory, Jackson2JsonMessageConverter converter) {
+    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory, Jackson2JsonMessageConverter converter) {
         RabbitTemplate rabbitTemplate = new RabbitTemplate();
 
         rabbitTemplate.setConnectionFactory(connectionFactory);
diff --git a/src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java b/src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java
index b8d3d51..f18ccbb 100644
--- a/src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java
+++ b/src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java
@@ -26,6 +26,8 @@ public class MessageConsumer {
     @RabbitHandler
     @RabbitListener(queues = {"app.drone.queue"})
     public void receivedDroneMessage(final String message) {
+        log.info("application message : {}", message);
+
         GPModel model = new GPModel();
 
         try {