Merge pull request AxonFramework#3156 from wtrzas2/fix-flaky-2

Fixed messageSerialization test in GenericMessageTest
lachja · Oct 17, 2024 · d7c6fcd · d7c6fcd
2 parents b2ae54b + 985d7b8
commit d7c6fcd
Showing 1 changed file with 16 additions and 5 deletions.
diff --git 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<String> message = new GenericMessage<>("payload", Collections.singletonMap("key", "value"));
-        Serializer jacksonSerializer = JacksonSerializer.builder().build();
+    void messageSerialization() throws IOException{
+        Map<String, String> metaDataMap = Collections.singletonMap("key", "value");
+
+        GenericMessage<String> message = new GenericMessage<>("payload", metaDataMap);
+
+        JacksonSerializer jacksonSerializer = JacksonSerializer.builder().build();
+
 
         SerializedObject<String> serializedPayload = message.serializePayload(jacksonSerializer, String.class);
         SerializedObject<String> serializedMetaData = message.serializeMetaData(jacksonSerializer, String.class);
 
         assertEquals("\"payload\"", serializedPayload.getData());
-        assertEquals("{\"key\":\"value\",\"foo\":\"bar\"}", serializedMetaData.getData());
+
+
+        ObjectMapper objectMapper = jacksonSerializer.getObjectMapper();
+        Map<String, String> actualMetaData = objectMapper.readValue(serializedMetaData.getData(), Map.class);
+
+         assertTrue(actualMetaData.entrySet().containsAll(metaDataMap.entrySet()));
     }
 
     @Test