summaryrefslogtreecommitdiff
path: root/src/main/kotlin
diff options
context:
space:
mode:
authorPaul-Christian Volkmer2025-11-06 16:27:14 +0100
committerGitHub2025-11-06 16:27:14 +0100
commit9aa9afc6e29c01366720adf1f53c5c358f876edb (patch)
tree2161a9dfc7f5ec721cd39a1ebbe024cb2399e946 /src/main/kotlin
parenta135b66c7b0567dc2a024a9434771c3a270021f7 (diff)
chore: change annotation for KT-73255 (#185)
This keeps old behavior in future releases.
Diffstat (limited to 'src/main/kotlin')
-rw-r--r--src/main/kotlin/dev/dnpm/etl/processor/monitoring/ConnectionCheckService.kt8
-rw-r--r--src/main/kotlin/dev/dnpm/etl/processor/services/kafka/KafkaResponseProcessor.kt6
-rw-r--r--src/main/kotlin/dev/dnpm/etl/processor/web/ConfigController.kt2
-rw-r--r--src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt2
4 files changed, 9 insertions, 9 deletions
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
) {