From e7f84c28d64a0da10ce15539470f268e78b98653 Mon Sep 17 00:00:00 2001 From: maverickstuder Date: Mon, 7 Oct 2024 12:21:12 +0200 Subject: [PATCH] Fix tenant-updated queue naming mismatch --- .../search/v1/server/queue/UpdatedTenantMessageReceiver.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/search-service-v1/search-service-server-v1/src/main/java/com/iqser/red/service/search/v1/server/queue/UpdatedTenantMessageReceiver.java b/search-service-v1/search-service-server-v1/src/main/java/com/iqser/red/service/search/v1/server/queue/UpdatedTenantMessageReceiver.java index 2a24ff0..cba0a89 100644 --- a/search-service-v1/search-service-server-v1/src/main/java/com/iqser/red/service/search/v1/server/queue/UpdatedTenantMessageReceiver.java +++ b/search-service-v1/search-service-server-v1/src/main/java/com/iqser/red/service/search/v1/server/queue/UpdatedTenantMessageReceiver.java @@ -21,7 +21,7 @@ public class UpdatedTenantMessageReceiver { private final IndexQueryService indexQueryService; private final IndexDeleteService indexDeleteService; - @Value("${fforesight.multitenancy.tenant-updated-queue:tenant-updated-queue}") + @Value("${fforesight.multitenancy.tenant-updated-queue:search-service-tenant-updated}") private String tenantUpdatedQueue; @@ -32,7 +32,7 @@ public class UpdatedTenantMessageReceiver { } - @RabbitListener(queues = "${fforesight.multitenancy.tenant-updated-queue:tenant-updated-queue}") + @RabbitListener(queues = "${fforesight.multitenancy.tenant-updated-queue:search-service-tenant-updated}") public void updateTenant(TenantResponse tenant) { String numberOfReplicas = tenant.getSearchConnection().getNumberOfReplicas();