From 978323c0c7ac97062be38a7437718f0575014136 Mon Sep 17 00:00:00 2001 From: maverickstuder Date: Wed, 3 Apr 2024 18:51:12 +0200 Subject: [PATCH] RED-8702: Explore document databases to store entityLog - renamed beans to avoid clash with database-tenant-commons --- .../MongoTenantMessagingConfiguration.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/knecon/fforesight/mongo/database/commons/MongoTenantMessagingConfiguration.java b/src/main/java/com/knecon/fforesight/mongo/database/commons/MongoTenantMessagingConfiguration.java index ba1892f..9f213f4 100644 --- a/src/main/java/com/knecon/fforesight/mongo/database/commons/MongoTenantMessagingConfiguration.java +++ b/src/main/java/com/knecon/fforesight/mongo/database/commons/MongoTenantMessagingConfiguration.java @@ -21,10 +21,10 @@ import lombok.RequiredArgsConstructor; public class MongoTenantMessagingConfiguration { @Value("${fforesight.mongo.multitenancy.tenant-created-queue:mongo-tenant-created}") - private String tenantCreatedEventQueue; + private String mongoTenantCreatedEventQueue; @Value("${fforesight.mongo.multitenancy.tenant-created-dlq:mongo-tenant-created-dlq}") - private String tenantCreatedDLQ; + private String mongoTenantCreatedDLQ; @Bean(name = "mongoTenantExchange") @@ -37,21 +37,21 @@ public class MongoTenantMessagingConfiguration { @Bean("persistenceServiceMongoTenantCreatedQueue") public Queue persistenceServiceMongoTenantCreatedQueue() { - return QueueBuilder.durable(tenantCreatedEventQueue) - .withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", tenantCreatedDLQ).build(); + return QueueBuilder.durable(mongoTenantCreatedEventQueue) + .withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", mongoTenantCreatedDLQ).build(); } - @Bean + @Bean("persistenceServiceMongoTenantDLQ") public Queue persistenceServiceMongoTenantDLQ() { - return QueueBuilder.durable(tenantCreatedDLQ).build(); + return QueueBuilder.durable(mongoTenantCreatedDLQ).build(); } - @Bean - public Binding tenantExchangeBinding(@Qualifier("persistenceServiceMongoTenantCreatedQueue") Queue persistenceServiceTenantCreatedQueue, - @Qualifier("mongoTenantExchange") TopicExchange tenantExchange) { + @Bean("mongoTenantExchangeBinding") + public Binding mongoTenantExchangeBinding(@Qualifier("persistenceServiceMongoTenantCreatedQueue") Queue persistenceServiceTenantCreatedQueue, + @Qualifier("mongoTenantExchange") TopicExchange tenantExchange) { return BindingBuilder.bind(persistenceServiceTenantCreatedQueue).to(tenantExchange).with("tenant.created"); }