Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @Bean
- TopicExchange exchange() {
- return new TopicExchange("mykaarma.messaging.event.exchange");
- }
- @Bean
- TopicExchange FailExchange() {
- return new TopicExchange("kaarma.crawler.fail.exchange");
- }
- @Bean
- Queue queue() {
- return QueueBuilder.durable(Application.getQueueName())
- .withArgument("x-dead-letter-routing-key", "mykaarma.qna.message.events.fail.key")
- .withArgument("x-dead-letter-exchange", Application.DEAD_LETTER_QUEUE_NAME)
- .build();
- }
- @Bean
- Binding binding(Queue queue,
- TopicExchange exchange) {
- return BindingBuilder.bind(queue()).to(exchange()).with("mykaarma.messaging.event.key");
- }
- @Bean
- Binding bindingFailQueue(Queue deadLetterQueue, TopicExchange FailExchange) {
- return BindingBuilder.bind(deadLetterQueue).to(FailExchange).with("mykaarma.qna.message.events.fail.key");
- }
- @Bean
- Queue deadLetterQueue() {
- return QueueBuilder.durable(Application.DEAD_LETTER_QUEUE_NAME).build();
- }
Add Comment
Please, Sign In to add comment