meesage connection 설정 변경

src/main/java/com/palnet/process/message/config/MessageConfig.java

@@ -22,17 +22,17 @@ public class MessageConfig {
     public MessageConfig(Environment env) {
         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() {
@@ -41,7 +41,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);

src/main/java/com/palnet/process/message/consumer/MessageConsumer.java

@@ -30,7 +30,7 @@ public class MessageConsumer {
     @RabbitHandler
     @RabbitListener(queues = {"websocket.drone.queue"})
     public void receiveDroneMessage(final String message) throws JsonProcessingException {
-//		log.info("websocket message : {}", message);
+		log.info("websocket message : {}", message);
 		GPModel model = objectMapper.readValue(message, GPModel.class);
 
 		CtrCntrlModel history = this.modelConvert(model); // 웹 표출 model로 변환