Browse Source

rabbitmq message config 수정

feature/auth
노승철 2 years ago
parent
commit
6e71aee2a7
  1. 90
      src/main/java/com/palnet/biz/config/MessageConfig.java

90
src/main/java/com/palnet/biz/config/MessageConfig.java

@ -22,59 +22,59 @@ 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() {
return new Jackson2JsonMessageConverter();
}
@Bean
public DirectExchange appDroneExchange() {
return new DirectExchange(env.getProperty("message.app.exchange-name"));
}
@Bean
public DirectExchange websocketDroneExchange() {
return new DirectExchange(env.getProperty("message.websocket.exchange-name"));
}
@Bean
public Queue appDroneQueue() {
return new Queue(env.getProperty("message.app.queue-name"), false);
}
@Bean
public Queue websocketDroneQueue() {
return new Queue(env.getProperty("message.websocket.queue-name"), false);
}
@Bean
public Binding appDroneBinding(Queue appDroneQueue, DirectExchange appDroneExchange) {
return BindingBuilder.bind(appDroneQueue)
.to(appDroneExchange)
.with(env.getProperty("message.app.routing-key"));
}
@Bean
public Binding websocketDroneBinding(Queue websocketDroneQueue, DirectExchange websocketDroneExchange) {
return BindingBuilder.bind(websocketDroneQueue)
.to(websocketDroneExchange)
.with(env.getProperty("message.websocket.routing-key"));
}
// @Bean
// public DirectExchange appDroneExchange() {
// return new DirectExchange(env.getProperty("message.app.exchange-name"));
// }
//
// @Bean
// public DirectExchange websocketDroneExchange() {
// return new DirectExchange(env.getProperty("message.websocket.exchange-name"));
// }
//
// @Bean
// public Queue appDroneQueue() {
// return new Queue(env.getProperty("message.app.queue-name"), false);
// }
//
// @Bean
// public Queue websocketDroneQueue() {
// return new Queue(env.getProperty("message.websocket.queue-name"), false);
// }
//
// @Bean
// public Binding appDroneBinding(Queue appDroneQueue, DirectExchange appDroneExchange) {
// return BindingBuilder.bind(appDroneQueue)
// .to(appDroneExchange)
// .with(env.getProperty("message.app.routing-key"));
// }
//
// @Bean
// public Binding websocketDroneBinding(Queue websocketDroneQueue, DirectExchange websocketDroneExchange) {
// return BindingBuilder.bind(websocketDroneQueue)
// .to(websocketDroneExchange)
// .with(env.getProperty("message.websocket.routing-key"));
// }
@Bean
public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory, Jackson2JsonMessageConverter converter) {
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory, Jackson2JsonMessageConverter converter) {
RabbitTemplate rabbitTemplate = new RabbitTemplate();
rabbitTemplate.setConnectionFactory(connectionFactory);

Loading…
Cancel
Save