diff --git a/messaging/src/test/java/org/axonframework/messaging/GenericMessageTest.java b/messaging/src/test/java/org/axonframework/messaging/GenericMessageTest.java index dfbdd0930c..963c6dee44 100644 --- a/messaging/src/test/java/org/axonframework/messaging/GenericMessageTest.java +++ b/messaging/src/test/java/org/axonframework/messaging/GenericMessageTest.java @@ -23,10 +23,12 @@ import org.axonframework.messaging.unitofwork.UnitOfWork; import org.axonframework.serialization.CannotConvertBetweenTypesException; import org.axonframework.serialization.SerializedObject; -import org.axonframework.serialization.Serializer; import org.axonframework.serialization.json.JacksonSerializer; import org.junit.jupiter.api.*; +import com.fasterxml.jackson.databind.ObjectMapper; + +import java.io.IOException; import java.util.Collections; import java.util.HashMap; import java.util.Map; @@ -68,15 +70,24 @@ void correlationDataAddedToNewMessage() { } @Test - void messageSerialization() { - GenericMessage message = new GenericMessage<>("payload", Collections.singletonMap("key", "value")); - Serializer jacksonSerializer = JacksonSerializer.builder().build(); + void messageSerialization() throws IOException{ + Map metaDataMap = Collections.singletonMap("key", "value"); + + GenericMessage message = new GenericMessage<>("payload", metaDataMap); + + JacksonSerializer jacksonSerializer = JacksonSerializer.builder().build(); + SerializedObject serializedPayload = message.serializePayload(jacksonSerializer, String.class); SerializedObject serializedMetaData = message.serializeMetaData(jacksonSerializer, String.class); assertEquals("\"payload\"", serializedPayload.getData()); - assertEquals("{\"key\":\"value\",\"foo\":\"bar\"}", serializedMetaData.getData()); + + + ObjectMapper objectMapper = jacksonSerializer.getObjectMapper(); + Map actualMetaData = objectMapper.readValue(serializedMetaData.getData(), Map.class); + + assertTrue(actualMetaData.entrySet().containsAll(metaDataMap.entrySet())); } @Test