From 8ac33bc0fe1b846a9f4e1e5ffc025daaee726881 Mon Sep 17 00:00:00 2001 From: Timo Bejan Date: Fri, 29 Apr 2022 20:17:50 +0300 Subject: [PATCH] Hotfix RED-3800 purge queue --- .../v1/server/internal/AdminInterfaceController.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/internal/AdminInterfaceController.java b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/internal/AdminInterfaceController.java index 721a76cc4..e7dea6f76 100644 --- a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/internal/AdminInterfaceController.java +++ b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/internal/AdminInterfaceController.java @@ -9,6 +9,7 @@ import com.iqser.red.service.persistence.service.v1.api.model.dossiertemplate.do import com.iqser.red.service.persistence.service.v1.api.model.dossiertemplate.dossier.file.WorkflowStatus; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; +import org.springframework.amqp.core.AmqpAdmin; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; @@ -25,8 +26,9 @@ public class AdminInterfaceController { private final FileManagementStorageService fileManagementStorageService; private final FileStatusService fileStatusService; private final FileManagementServiceSettings fileManagementServiceSettings; - private final DossierService dossierService; + private final AmqpAdmin amqpAdmin; + @PostMapping("/reset-file") @@ -140,4 +142,10 @@ public class AdminInterfaceController { } } + @PostMapping("/flush-queue") + public void resetText(@RequestParam() String queueName ) { + amqpAdmin.purgeQueue(queueName); + } + + }