Browse Source

message config 수정

master
노승철 2 years ago
parent
commit
e083bbef13
  1. 24
      src/main/java/com/palnet/process/message/config/MessageConfig.java

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

Loading…
Cancel
Save