Guest User

Untitled

a guest
Jul 18th, 2019
45
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.97 KB | None | 0 0
  1. @Bean
  2. TopicExchange exchange() {
  3. return new TopicExchange("mykaarma.messaging.event.exchange");
  4. }
  5.  
  6. @Bean
  7. TopicExchange FailExchange() {
  8. return new TopicExchange("kaarma.crawler.fail.exchange");
  9. }
  10.  
  11.  
  12.  
  13. @Bean
  14. Queue queue() {
  15. return QueueBuilder.durable(Application.getQueueName())
  16. .withArgument("x-dead-letter-routing-key", "mykaarma.qna.message.events.fail.key")
  17. .withArgument("x-dead-letter-exchange", Application.DEAD_LETTER_QUEUE_NAME)
  18. .build();
  19. }
  20. @Bean
  21. Binding binding(Queue queue,
  22. TopicExchange exchange) {
  23. return BindingBuilder.bind(queue()).to(exchange()).with("mykaarma.messaging.event.key");
  24. }
  25.  
  26. @Bean
  27. Binding bindingFailQueue(Queue deadLetterQueue, TopicExchange FailExchange) {
  28. return BindingBuilder.bind(deadLetterQueue).to(FailExchange).with("mykaarma.qna.message.events.fail.key");
  29.  
  30. }
  31.  
  32. @Bean
  33. Queue deadLetterQueue() {
  34. return QueueBuilder.durable(Application.DEAD_LETTER_QUEUE_NAME).build();
  35. }
Add Comment
Please, Sign In to add comment