Skip to content

Commit 51cfdb5

Browse files
committed
test: add missing test
1 parent c3683ed commit 51cfdb5

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

kafka/src/test/java/org/axonframework/extensions/kafka/eventhandling/HeaderUtilsTest.java

+10
Original file line numberDiff line numberDiff line change
@@ -127,15 +127,25 @@ void testReadingValuesAsLongExistingKeyShouldReturnLong() {
127127
addHeader(headers, "negative", -4_8912_00_921_388_62621L);
128128

129129
assertEquals(4_891_00_921_388_62621L, valueAsLong(headers, "positive"));
130+
assertEquals(4_891_00_921_388_62621L, valueAsLong(headers, "positive", 42L));
130131
assertEquals(0, valueAsLong(headers, "zero"));
132+
assertEquals(0, valueAsLong(headers, "zero", 42L));
131133
assertEquals(-4_8912_00_921_388_62621L, valueAsLong(headers, "negative"));
134+
135+
assertEquals(-4_8912_00_921_388_62621L, valueAsLong(headers, "negative", 42L));
136+
132137
}
133138

134139
@Test
135140
void testReadingValueAsLongNonExistingKeyShouldReturnNull() {
136141
assertNull(valueAsLong(new RecordHeaders(), "some-invalid-key"));
137142
}
138143

144+
@Test
145+
void testReadingValueAsLongNonExistingKeyShouldReturnDefaultValue() {
146+
assertEquals(42L, valueAsLong(new RecordHeaders(), "some-invalid-key", 42L));
147+
}
148+
139149
@Test
140150
void testWritingTimestampShouldBeWrittenAsLong() {
141151
RecordHeaders target = new RecordHeaders();

0 commit comments

Comments
 (0)