diff --git a/tests/messagebus/message_consume_test.go b/tests/messagebus/message_consume_test.go
index e96261e16..e8b3da0c1 100644
--- a/tests/messagebus/message_consume_test.go
+++ b/tests/messagebus/message_consume_test.go
@@ -79,7 +79,7 @@ func TestMessageWrite(t *testing.T) {
 				set := h.checkPersistedMessages(ctx, messagebus.QueueMessageFilter{})
 
 				// success, will eventually get persisted
-				if len(set) == 2 {
+				if len(set) >= 2 {
 					h.a.NotEmpty(set)
 					h.a.Equal([]byte(`this is a test`), set[0].Payload)
 					h.a.Equal([]byte(`foo bar`), set[1].Payload)