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);
+    }
+
+
 }