From 13f6e8d1dd89878d9926d5e8f4a92c85d6cb44fc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?scnoh=28=EB=85=B8=EC=8A=B9=EC=B2=A0=29?= Date: Thu, 25 Aug 2022 11:15:43 +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 --- .../process/message/config/MessageConfig.java | 24 +++++++++---------- .../message/consumer/MessageConsumer.java | 2 +- 2 files changed, 13 insertions(+), 13 deletions(-) diff --git a/src/main/java/com/palnet/process/message/config/MessageConfig.java b/src/main/java/com/palnet/process/message/config/MessageConfig.java index bcb6eca..200252b 100644 --- a/src/main/java/com/palnet/process/message/config/MessageConfig.java +++ b/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); diff --git a/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java b/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java index 0dfe2ea..84c7fa0 100644 --- a/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java +++ b/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로 변환