diff --git a/src/main/java/com/palnet/biz/config/MessageConfig.java b/src/main/java/com/palnet/biz/config/MessageConfig.java index 026e5bb..6d6a17c 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(ConnectionFactory connectionFactory, Jackson2JsonMessageConverter converter) { + public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory, Jackson2JsonMessageConverter converter) { RabbitTemplate rabbitTemplate = new RabbitTemplate(); rabbitTemplate.setConnectionFactory(connectionFactory);