summaryrefslogtreecommitdiff
path: root/src/test
diff options
context:
space:
mode:
authorPaul-Christian Volkmer2025-10-31 16:54:33 +0100
committerGitHub2025-10-31 16:54:33 +0100
commit7ced45b3d6499863b8cc18193b08e8e362e466e4 (patch)
tree44f20da5cbf98934490e6e7fbf3c2e70df8425c7 /src/test
parent2cb2b60091405ca95c1f134f5d995e0fc30c908a (diff)
fix: only send nested content with MTB record (#175)
Diffstat (limited to 'src/test')
-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)