Added test exchanges

a-dubaj · Mar 31, 2022 · 32d7595 · 32d7595
1 parent 3f78ae9
commit 32d7595
Showing 1 changed file with 28 additions and 0 deletions.
diff --git a/src/main/java/com/andrzejdubaj/rabbitmqdemoapp/RabbitMqExchangeConfiguration.java b/src/main/java/com/andrzejdubaj/rabbitmqdemoapp/RabbitMqExchangeConfiguration.java
@@ -5,6 +5,7 @@
 import org.springframework.amqp.core.TopicExchange;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.retry.annotation.Backoff;
 
 @Configuration
 public class RabbitMqExchangeConfiguration {
@@ -21,4 +22,31 @@ Exchange example2exchange() {
                 .internal()
                 .build();
     }
+
+    @Bean
+    Exchange newExchange() {
+        return ExchangeBuilder.topicExchange("TopicTestExchange")
+                .autoDelete()
+                .durable(true)
+                .internal()
+                .build();
+    }
+
+    @Bean
+    Exchange fanoutExchange(){
+        return ExchangeBuilder.fanoutExchange("FanoutTestExchange")
+                .autoDelete()
+                .durable(false)
+                .internal()
+                .build();
+    }
+
+    @Bean
+    Exchange headersExchange(){
+        return ExchangeBuilder.headersExchange("HeadersTestExchange")
+                .internal()
+                .durable(true)
+                .ignoreDeclarationExceptions()
+                .build();
+    }
 }