diff --git a/UserService/src/main/java/com/skipass/userservice/messaging/RabbitMQConfig.java b/UserService/src/main/java/com/skipass/userservice/messaging/RabbitMQConfig.java index 26d4142..f40073c 100644 --- 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 index 07697b2..86cf904 100644 --- 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": [