Merge pull request #51 from tilakraj94/modify-test-case

Add multiple messages to verify order
synadia-io · Feb 10, 2025 · 720f80f · 720f80f
2 parents a7cc07c + 057a970
commit 720f80f
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/src/test/java/io/synadia/io/synadia/flink/v0/SerializersDeserializersTests.java b/src/test/java/io/synadia/io/synadia/flink/v0/SerializersDeserializersTests.java
@@ -129,7 +129,15 @@ private static List<Message> generateMessages(String subject, boolean headersNul
             builder.replyTo("_inbox." + subject);
         }
 
-        messages.add(builder.subject(subject).data(subject.getBytes()).build());
+        Message firstMessage = builder.subject(subject).data(subject + "1").build();
+        Message secondMessage = builder.subject(subject).data(subject + "2").build();
+        Message thirdMessage = builder.subject(subject).data(subject + "3").build();
+        Message fourthMessage = builder.subject(subject).data(subject + "4").build();
+
+        messages.add(firstMessage);
+        messages.add(secondMessage);
+        messages.add(thirdMessage);
+        messages.add(fourthMessage);
         return messages;
     }