diff options
| author | Paul-Christian Volkmer | 2024-02-19 17:06:02 +0100 |
|---|---|---|
| committer | Paul-Christian Volkmer | 2024-02-19 17:06:02 +0100 |
| commit | 50a6d66718abbf08368c41ec9c0df536cf5771c1 (patch) | |
| tree | 0c32d339f2d4e37ede0787541d307cb1403ac14d /src/test/kotlin/dev | |
| parent | f5c80f6d8157dabaac7df2db1fbf824fa85cd8a0 (diff) | |
feat: new kafka config due to kafka input
Diffstat (limited to 'src/test/kotlin/dev')
| -rw-r--r-- | src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt b/src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt index d0f7c30..ff5b1ae 100644 --- a/src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt +++ b/src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt @@ -21,7 +21,7 @@ package dev.dnpm.etl.processor.output import com.fasterxml.jackson.databind.ObjectMapper import de.ukw.ccc.bwhc.dto.* -import dev.dnpm.etl.processor.config.KafkaTargetProperties +import dev.dnpm.etl.processor.config.KafkaProperties import dev.dnpm.etl.processor.monitoring.RequestStatus import org.assertj.core.api.Assertions.assertThat import org.junit.jupiter.api.BeforeEach @@ -53,13 +53,13 @@ class KafkaMtbFileSenderTest { fun setup( @Mock kafkaTemplate: KafkaTemplate<String, String> ) { - val kafkaTargetProperties = KafkaTargetProperties("testtopic") + val kafkaProperties = KafkaProperties("testtopic") val retryTemplate = RetryTemplateBuilder().customPolicy(SimpleRetryPolicy(1)).build() this.objectMapper = ObjectMapper() this.kafkaTemplate = kafkaTemplate - this.kafkaMtbFileSender = KafkaMtbFileSender(kafkaTemplate, kafkaTargetProperties, retryTemplate, objectMapper) + this.kafkaMtbFileSender = KafkaMtbFileSender(kafkaTemplate, kafkaProperties, retryTemplate, objectMapper) } @ParameterizedTest @@ -125,9 +125,9 @@ class KafkaMtbFileSenderTest { @ParameterizedTest @MethodSource("requestWithResponseSource") fun shouldRetryOnMtbFileKafkaSendError(testData: TestData) { - val kafkaTargetProperties = KafkaTargetProperties("testtopic") + val kafkaProperties = KafkaProperties("testtopic") val retryTemplate = RetryTemplateBuilder().customPolicy(SimpleRetryPolicy(3)).build() - this.kafkaMtbFileSender = KafkaMtbFileSender(this.kafkaTemplate, kafkaTargetProperties, retryTemplate, this.objectMapper) + this.kafkaMtbFileSender = KafkaMtbFileSender(this.kafkaTemplate, kafkaProperties, retryTemplate, this.objectMapper) doAnswer { if (null != testData.exception) { @@ -151,9 +151,9 @@ class KafkaMtbFileSenderTest { @ParameterizedTest @MethodSource("requestWithResponseSource") fun shouldRetryOnDeleteKafkaSendError(testData: TestData) { - val kafkaTargetProperties = KafkaTargetProperties("testtopic") + val kafkaProperties = KafkaProperties("testtopic") val retryTemplate = RetryTemplateBuilder().customPolicy(SimpleRetryPolicy(3)).build() - this.kafkaMtbFileSender = KafkaMtbFileSender(this.kafkaTemplate, kafkaTargetProperties, retryTemplate, this.objectMapper) + this.kafkaMtbFileSender = KafkaMtbFileSender(this.kafkaTemplate, kafkaProperties, retryTemplate, this.objectMapper) doAnswer { if (null != testData.exception) { |