Marmelator/persistence-service
1
0
Fork 0
Code Issues Pull Requests 17 Actions Packages Projects Releases 1.1k Wiki Activity

Hotfix RED-3800 purge queue

Browse Source
This commit is contained in:
Timo Bejan 2022-04-29 20:17:50 +03:00
parent 342b2dddcd
commit 8ac33bc0fe
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/internal/AdminInterfaceController.java
View File

@ -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 com.iqser.red.service.persistence.service.v1.api.model.dossiertemplate.dossier.file.WorkflowStatus;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RequestParam;
@ -25,8 +26,9 @@ public class AdminInterfaceController {
private final FileManagementStorageService fileManagementStorageService; private final FileManagementStorageService fileManagementStorageService;
private final FileStatusService fileStatusService; private final FileStatusService fileStatusService;
private final FileManagementServiceSettings fileManagementServiceSettings; private final FileManagementServiceSettings fileManagementServiceSettings;
private final DossierService dossierService; private final DossierService dossierService;
private final AmqpAdmin amqpAdmin;
@PostMapping("/reset-file") @PostMapping("/reset-file")
@ -140,4 +142,10 @@ public class AdminInterfaceController {
} }
} }
@PostMapping("/flush-queue")
public void resetText(@RequestParam() String queueName ) {
amqpAdmin.purgeQueue(queueName);
}
} }