Added statistics update using SSE for delete requests

2025-07-01 14:12:55 +00:00 · 2023-08-01 13:54:26 +02:00
parent 7a7ea8c96d
commit ccf6908223
1 changed files with 4 additions and 0 deletions
--- a/src/main/kotlin/dev/dnpm/etl/processor/services/RequestProcessor.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/services/RequestProcessor.kt
@ -179,6 +179,8 @@ class RequestProcessor(
                )
            )

+            statisticsUpdateProducer.emitNext("", Sinks.EmitFailureHandler.FAIL_FAST)
+
            return overallRequestStatus
        } catch (e: Exception) {
            requestRepository.save(
@ -193,6 +195,8 @@ class RequestProcessor(
                )
            )

+            statisticsUpdateProducer.emitNext("", Sinks.EmitFailureHandler.FAIL_FAST)
+
            return RequestStatus.ERROR
        }
    }