diff options
| author | Paul-Christian Volkmer | 2024-02-29 08:51:28 +0100 |
|---|---|---|
| committer | Paul-Christian Volkmer | 2024-02-29 08:57:00 +0100 |
| commit | 46ddaf10f7a5f0f3da121ef219442109a209db0b (patch) | |
| tree | e8bab6455f7aa41bb168dd9689fc5df923782929 /src/test | |
| parent | 25f286f73bb649558850d69bf063130ede3cfc08 (diff) | |
| parent | 408b121f269b49da1b2dbfa4c3d7190b6df6b010 (diff) | |
Merge pull request #45 from CCC-MF/issue_34
Verwendung einer applikationsweiten Retry-Konfiguration
Diffstat (limited to 'src/test')
| -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) { |