diff options
| author | Paul-Christian Volkmer | 2025-10-31 16:54:33 +0100 |
|---|---|---|
| committer | Paul-Christian Volkmer | 2025-10-31 20:35:00 +0100 |
| commit | dedcec4ad59462b97531e498e8e388688bd0b8b1 (patch) | |
| tree | cf58583e3cd9d9341d9d352eac6bac2be5c81786 /src/test | |
| parent | eaadab88b80062432705bb5fbf295bde91143e76 (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.kt | 4 |
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) |
