summaryrefslogtreecommitdiff
path: root/src/test/kotlin/dev/dnpm
diff options
context:
space:
mode:
authorPaul-Christian Volkmer2025-10-31 16:54:33 +0100
committerPaul-Christian Volkmer2025-10-31 20:35:00 +0100
commitdedcec4ad59462b97531e498e8e388688bd0b8b1 (patch)
treecf58583e3cd9d9341d9d352eac6bac2be5c81786 /src/test/kotlin/dev/dnpm
parenteaadab88b80062432705bb5fbf295bde91143e76 (diff)
fix: only send nested content with MTB record (#175)
Diffstat (limited to 'src/test/kotlin/dev/dnpm')
-rw-r--r--src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt4
1 files changed, 2 insertions, 2 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 d13d5e1..022b8dd 100644
--- a/src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt
+++ b/src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt
@@ -224,8 +224,8 @@ class KafkaMtbFileSenderTest {
}
}
- fun dnmpV2kafkaRecordData(requestId: RequestId): MtbRequest {
- return DnpmV2MtbFileRequest(requestId, dnpmV2MtbFile())
+ fun dnmpV2kafkaRecordData(requestId: RequestId): Mtb {
+ return DnpmV2MtbFileRequest(requestId, dnpmV2MtbFile()).content
}
data class TestData(val requestStatus: RequestStatus, val exception: Throwable? = null)