From 9aa9afc6e29c01366720adf1f53c5c358f876edb Mon Sep 17 00:00:00 2001
From: Paul-Christian Volkmer
Date: Thu, 6 Nov 2025 16:27:14 +0100
Subject: chore: change annotation for KT-73255 (#185)

This keeps old behavior in future releases.---
 .../dev/dnpm/etl/processor/monitoring/ConnectionCheckService.kt   | 8 ++++----
 .../dnpm/etl/processor/services/kafka/KafkaResponseProcessor.kt   | 6 +++---
 src/main/kotlin/dev/dnpm/etl/processor/web/ConfigController.kt    | 2 +-
 .../kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt | 2 +-
 4 files changed, 9 insertions(+), 9 deletions(-)

(limited to 'src/main/kotlin')

diff --git a/src/main/kotlin/dev/dnpm/etl/processor/monitoring/ConnectionCheckService.kt b/src/main/kotlin/dev/dnpm/etl/processor/monitoring/ConnectionCheckService.kt
index bf8b8bd..6e97865 100644
--- a/src/main/kotlin/dev/dnpm/etl/processor/monitoring/ConnectionCheckService.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/monitoring/ConnectionCheckService.kt
@@ -80,7 +80,7 @@ sealed class ConnectionCheckResult {
 
 class KafkaConnectionCheckService(
     private val consumer: Consumer<String, String>,
-    @Qualifier("connectionCheckUpdateProducer")
+    @param:Qualifier("connectionCheckUpdateProducer")
     private val connectionCheckUpdateProducer: Sinks.Many<ConnectionCheckResult>
 ) : OutputConnectionCheckService {
 
@@ -120,7 +120,7 @@ class KafkaConnectionCheckService(
 class RestConnectionCheckService(
     private val restTemplate: RestTemplate,
     private val restTargetProperties: RestTargetProperties,
-    @Qualifier("connectionCheckUpdateProducer")
+    @param:Qualifier("connectionCheckUpdateProducer")
     private val connectionCheckUpdateProducer: Sinks.Many<ConnectionCheckResult>
 ) : OutputConnectionCheckService {
 
@@ -171,7 +171,7 @@ class RestConnectionCheckService(
 class GPasConnectionCheckService(
     private val restTemplate: RestTemplate,
     private val gPasConfigProperties: GPasConfigProperties,
-    @Qualifier("connectionCheckUpdateProducer")
+    @param:Qualifier("connectionCheckUpdateProducer")
     private val connectionCheckUpdateProducer: Sinks.Many<ConnectionCheckResult>
 ) : ConnectionCheckService {
 
@@ -229,7 +229,7 @@ class GPasConnectionCheckService(
 class GIcsConnectionCheckService(
     private val restTemplate: RestTemplate,
     private val gIcsConfigProperties: GIcsConfigProperties,
-    @Qualifier("connectionCheckUpdateProducer")
+    @param:Qualifier("connectionCheckUpdateProducer")
     private val connectionCheckUpdateProducer: Sinks.Many<ConnectionCheckResult>
 ) : ConnectionCheckService {
 
diff --git a/src/main/kotlin/dev/dnpm/etl/processor/services/kafka/KafkaResponseProcessor.kt b/src/main/kotlin/dev/dnpm/etl/processor/services/kafka/KafkaResponseProcessor.kt
index 12e824d..fd6a9b4 100644
--- a/src/main/kotlin/dev/dnpm/etl/processor/services/kafka/KafkaResponseProcessor.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/services/kafka/KafkaResponseProcessor.kt
@@ -73,9 +73,9 @@ class KafkaResponseProcessor(
     }
 
     data class ResponseBody(
-        @JsonProperty("request_id") @JsonAlias("requestId") val requestId: String,
-        @JsonProperty("status_code") @JsonAlias("statusCode") val statusCode: Int,
-        @JsonProperty("status_body") @JsonAlias("statusBody") val statusBody: Map<String, Any>
+        @param:JsonProperty("request_id") @param:JsonAlias("requestId") val requestId: String,
+        @param:JsonProperty("status_code") @param:JsonAlias("statusCode") val statusCode: Int,
+        @param:JsonProperty("status_body") @param:JsonAlias("statusBody") val statusBody: Map<String, Any>
     )
 
 }
\ No newline at end of file
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 ea89e98..44571d4 100644
--- a/src/main/kotlin/dev/dnpm/etl/processor/web/ConfigController.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/web/ConfigController.kt
@@ -40,7 +40,7 @@ import reactor.core.publisher.Sinks
 @Controller
 @RequestMapping(path = ["configs"])
 class ConfigController(
-    @Qualifier("connectionCheckUpdateProducer")
+    @param:Qualifier("connectionCheckUpdateProducer")
     private val connectionCheckUpdateProducer: Sinks.Many<ConnectionCheckResult>,
     private val transformationService: TransformationService,
     private val pseudonymGenerator: Generator,
diff --git a/src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt b/src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt
index c034cb4..8372274 100644
--- a/src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt
@@ -39,7 +39,7 @@ import java.time.temporal.ChronoUnit
 @RestController
 @RequestMapping(path = ["/statistics"])
 class StatisticsRestController(
-    @Qualifier("statisticsUpdateProducer")
+    @param:Qualifier("statisticsUpdateProducer")
     private val statisticsUpdateProducer: Sinks.Many<Any>,
     private val requestService: RequestService
 ) {
-- 
cgit v1.2.3