Fix tenant-updated queue naming mismatch

This commit is contained in:
maverickstuder 2024-10-07 12:21:12 +02:00
parent 779acf6202
commit e7f84c28d6

View File

@ -21,7 +21,7 @@ public class UpdatedTenantMessageReceiver {
private final IndexQueryService indexQueryService; private final IndexQueryService indexQueryService;
private final IndexDeleteService indexDeleteService; 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; 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) { public void updateTenant(TenantResponse tenant) {
String numberOfReplicas = tenant.getSearchConnection().getNumberOfReplicas(); String numberOfReplicas = tenant.getSearchConnection().getNumberOfReplicas();