From 122be08b6aa735fe37373019a2703c4e107f0019 Mon Sep 17 00:00:00 2001 From: Vivek Patel Date: Mon, 4 Oct 2021 16:30:23 +0530 Subject: [PATCH] Fixes messagebus test Fixed condition in TestMessageWrite, To prevent it from failing when there are more messages in queue --- tests/messagebus/message_consume_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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)