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 {