Skip to content

Commit

Permalink
match user service rabbitmq config to custom config
Browse files Browse the repository at this point in the history
AleksandraKrasteva committed Apr 7, 2024
1 parent 7afa569 commit 92b8e61
Showing 2 changed files with 5 additions and 6 deletions.
Original file line number Diff line number Diff line change
@@ -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());
}


}

5 changes: 1 addition & 4 deletions config/rabbitmq/definitions.json
Original file line number Diff line number Diff line change
@@ -43,10 +43,7 @@
"vhost": "/",
"durable": true,
"auto_delete": false,
"arguments": {
"x-max-length": 5,
"x-queue-type": "classic"
}
"arguments": {}
}
],
"exchanges": [

0 comments on commit 92b8e61

Please sign in to comment.