Merge pull request #10 from AleksandraKrasteva/test_setup

match user service rabbitmq config to custom config
AleksandraKrasteva · Apr 7, 2024 · 8ce0466 · 8ce0466
2 parents 4d75cc5 + 92b8e61
commit 8ce0466
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 6 deletions.
diff --git a/UserService/src/main/java/com/skipass/userservice/messaging/RabbitMQConfig.java b/UserService/src/main/java/com/skipass/userservice/messaging/RabbitMQConfig.java
@@ -18,7 +18,7 @@ public class RabbitMQConfig {
 
     @Bean
     public FanoutExchange deleteProfileExchange() {
-        return new FanoutExchange(fanoutExchangeName);
+        return new FanoutExchange(fanoutExchangeName, true, false);
     }
 
     @Bean
@@ -28,7 +28,7 @@ public Queue statisticsQueue() {
 
     @Bean
     public Queue postsQueue() {
-        return new Queue(postsQueueName);
+        return new Queue(postsQueueName, true);
     }
 
     @Bean
@@ -50,5 +50,7 @@ public Binding postsBinding() {
     public Binding journeyBinding() {
         return BindingBuilder.bind(journeyQueue()).to(deleteProfileExchange());
     }
+
+
 }
 
diff --git a/config/rabbitmq/definitions.json b/config/rabbitmq/definitions.json
@@ -43,10 +43,7 @@
           "vhost": "/",
           "durable": true,
           "auto_delete": false,
-          "arguments": {
-              "x-max-length": 5,
-              "x-queue-type": "classic"
-          }
+          "arguments": {}
       }
   ],
   "exchanges": [