From 52171e8ebef6bc92da0782ad46b47e22904aec84 Mon Sep 17 00:00:00 2001 From: Paul-Christian Volkmer Date: Wed, 8 May 2024 09:18:29 +0200 Subject: test: add test for config SSE endpoint --- src/main/kotlin/dev/dnpm/etl/processor/web/ConfigController.kt | 1 + 1 file changed, 1 insertion(+) (limited to 'src/main/kotlin/dev/dnpm') diff --git a/src/main/kotlin/dev/dnpm/etl/processor/web/ConfigController.kt b/src/main/kotlin/dev/dnpm/etl/processor/web/ConfigController.kt index 165535f..25ec7cc 100644 --- a/src/main/kotlin/dev/dnpm/etl/processor/web/ConfigController.kt +++ b/src/main/kotlin/dev/dnpm/etl/processor/web/ConfigController.kt @@ -183,6 +183,7 @@ class ConfigController( } @GetMapping(path = ["events"], produces = [MediaType.TEXT_EVENT_STREAM_VALUE]) + @ResponseBody fun events(): Flux> { return connectionCheckUpdateProducer.asFlux().map { val event = when (it) { -- cgit v1.2.3