Browse Source

message config 수정

feature/auth
노승철 2 years ago
parent
commit
7938d88e5f
  1. 24
      src/main/java/com/palnet/biz/config/MessageConfig.java

24
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);

Loading…
Cancel
Save