This is an automated email from the ASF dual-hosted git repository.
maciej pushed a commit to branch iggy_header_reserved
in repository https://gitbox.apache.org/repos/asf/iggy.git
The following commit(s) were added to refs/heads/iggy_header_reserved by this
push:
new 6ee5a178c update java tests
6ee5a178c is described below
commit 6ee5a178ce3f5fc387d40b7f6ec7911446e3ee9c
Author: Maciej Modzelewski <[email protected]>
AuthorDate: Mon Feb 2 12:33:35 2026 +0100
update java tests
---
.../client/blocking/http/ObjectMapperTest.java | 9 ++-
.../apache/iggy/serde/BytesDeserializerTest.java | 78 ----------------------
2 files changed, 6 insertions(+), 81 deletions(-)
diff --git
a/foreign/java/java-sdk/src/test/java/org/apache/iggy/client/blocking/http/ObjectMapperTest.java
b/foreign/java/java-sdk/src/test/java/org/apache/iggy/client/blocking/http/ObjectMapperTest.java
index eefda1659..53c8f58bc 100644
---
a/foreign/java/java-sdk/src/test/java/org/apache/iggy/client/blocking/http/ObjectMapperTest.java
+++
b/foreign/java/java-sdk/src/test/java/org/apache/iggy/client/blocking/http/ObjectMapperTest.java
@@ -59,7 +59,8 @@ class ObjectMapperTest {
"timestamp": 0,
"origin_timestamp": 1000,
"user_headers_length": 0,
- "payload_length": 4
+ "payload_length": 4,
+ "reserved": 0
},
"payload": "dGVzdA==",
"user_headers": []
@@ -94,7 +95,8 @@ class ObjectMapperTest {
"timestamp": 0,
"origin_timestamp": 1000,
"user_headers_length": 62,
- "payload_length": 4
+ "payload_length": 4,
+ "reserved": 0
},
"payload": "dGVzdA==",
"user_headers": [
@@ -186,7 +188,8 @@ class ObjectMapperTest {
"timestamp": 0,
"origin_timestamp": 0,
"user_headers_length": 0,
- "payload_length": 4
+ "payload_length": 4,
+ "reserved": 0
},
"payload": "%s",
"user_headers": []
diff --git
a/foreign/java/java-sdk/src/test/java/org/apache/iggy/serde/BytesDeserializerTest.java
b/foreign/java/java-sdk/src/test/java/org/apache/iggy/serde/BytesDeserializerTest.java
index c9b570ac0..22ce77a75 100644
---
a/foreign/java/java-sdk/src/test/java/org/apache/iggy/serde/BytesDeserializerTest.java
+++
b/foreign/java/java-sdk/src/test/java/org/apache/iggy/serde/BytesDeserializerTest.java
@@ -755,82 +755,4 @@ class BytesDeserializerTest {
assertThat(tokenInfo.expiryAt()).isEmpty();
}
}
-
- @Nested
- class JsonDeserialization {
-
- private static final tools.jackson.databind.ObjectMapper MAPPER =
-
org.apache.iggy.client.blocking.http.ObjectMapperFactory.getInstance();
-
- @Test
- void shouldDeserializePolledMessagesWithEmptyUserHeaders() throws
Exception {
- String json = """
- {
- "partition_id": 1,
- "current_offset": 10,
- "count": 1,
- "messages": [
- {
- "header": {
- "checksum": 0,
- "id": 42,
- "offset": 0,
- "timestamp": 0,
- "origin_timestamp": 1000,
- "user_headers_length": 0,
- "payload_length": 4,
- "reserved": 0
- },
- "payload": "dGVzdA==",
- "user_headers": []
- }
- ]
- }
- """;
-
- var polledMessages = MAPPER.readValue(json,
org.apache.iggy.message.PolledMessages.class);
-
- assertThat(polledMessages).isNotNull();
- assertThat(polledMessages.messages()).hasSize(1);
-
assertThat(polledMessages.messages().get(0).userHeaders()).isEmpty();
- }
-
- @Test
- void shouldDeserializePolledMessagesWithUserHeaders() throws Exception
{
- String json = """
- {
- "partition_id": 1,
- "current_offset": 10,
- "count": 1,
- "messages": [
- {
- "header": {
- "checksum": 0,
- "id": 42,
- "offset": 0,
- "timestamp": 0,
- "origin_timestamp": 1000,
- "user_headers_length": 62,
- "payload_length": 4,
- "reserved": 0
- },
- "payload": "dGVzdA==",
- "user_headers": [
- {
- "key": {"kind": "string", "value":
"Y29udGVudC10eXBl"},
- "value": {"kind": "string", "value":
"dGV4dC9wbGFpbg=="}
- }
- ]
- }
- ]
- }
- """;
-
- var polledMessages = MAPPER.readValue(json,
org.apache.iggy.message.PolledMessages.class);
-
- assertThat(polledMessages).isNotNull();
- assertThat(polledMessages.messages()).hasSize(1);
-
assertThat(polledMessages.messages().get(0).userHeaders()).hasSize(1);
- }
- }
}
