diff --git a/src/main/java/com/palnet/biz/config/MessageConfig.java b/src/main/java/com/palnet/biz/config/MessageConfig.java index 6d6a17c..f894ed8 100644 --- a/src/main/java/com/palnet/biz/config/MessageConfig.java +++ b/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);