From e083bbef13490092d8cf91258613e2cf6b71c24f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?scnoh=28=EB=85=B8=EC=8A=B9=EC=B2=A0=29?= Date: Mon, 29 Aug 2022 17:56:23 +0900 Subject: [PATCH] =?UTF-8?q?message=20config=20=EC=88=98=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../process/message/config/MessageConfig.java | 24 +++++++++---------- 1 file changed, 12 insertions(+), 12 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 5688531..e394e14 100644 --- a/src/main/java/com/palnet/process/message/config/MessageConfig.java +++ b/src/main/java/com/palnet/process/message/config/MessageConfig.java @@ -61,20 +61,20 @@ public class MessageConfig { .with(env.getProperty("message.websocket.routing-key")); } -// @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 RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory, Jackson2JsonMessageConverter converter) { + public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory, Jackson2JsonMessageConverter converter) { RabbitTemplate rabbitTemplate = new RabbitTemplate(); rabbitTemplate.setConnectionFactory(connectionFactory);