From ae29f2ec89694fde008ed7a5e654c82205854003 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Dominique=20Eifl=C3=A4nder?= Date: Tue, 16 Jul 2024 10:26:09 +0200 Subject: [PATCH] RED-9658: Remove old ocr service queues in migration --- .../processor/migration/OldQueueCleanup.java | 37 +++++++++++++++++++ 1 file changed, 37 insertions(+) create mode 100644 persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/OldQueueCleanup.java diff --git a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/OldQueueCleanup.java b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/OldQueueCleanup.java new file mode 100644 index 000000000..816e64296 --- /dev/null +++ b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/OldQueueCleanup.java @@ -0,0 +1,37 @@ +package com.iqser.red.service.persistence.management.v1.processor.migration; + +import static com.iqser.red.service.persistence.management.v1.processor.configuration.MessagingConfiguration.OCR_STATUS_UPDATE_RESPONSE_DQL; +import static com.iqser.red.service.persistence.management.v1.processor.configuration.MessagingConfiguration.OCR_STATUS_UPDATE_RESPONSE_QUEUE; + +import org.springframework.amqp.core.AmqpAdmin; +import org.springframework.beans.factory.InitializingBean; + +import com.iqser.red.service.persistence.management.v1.processor.settings.FileManagementServiceSettings; + +import lombok.RequiredArgsConstructor; + +// This can not run with migration starter service, it needs to be an InitializingBean otherwise it would be executed after queue listeners are initialized + +@RequiredArgsConstructor +public class OldQueueCleanup implements InitializingBean { + + private final AmqpAdmin amqpAdmin; + private final FileManagementServiceSettings settings; + + public static final String OCR_QUEUE = "ocrQueue"; + public static final String OCR_DLQ = "ocrDLQ"; + + + @Override + public void afterPropertiesSet() { + + // This should only run in post upgrade hook + if (settings.isMigrateOnly()) { + amqpAdmin.deleteQueue(OCR_QUEUE); + amqpAdmin.deleteQueue(OCR_DLQ); + amqpAdmin.deleteQueue(OCR_STATUS_UPDATE_RESPONSE_QUEUE); + amqpAdmin.deleteQueue(OCR_STATUS_UPDATE_RESPONSE_DQL); + } + } + +} -- 2.47.2