From e2eeaf5f3d95438e542ecf43b399c65a213faec7 Mon Sep 17 00:00:00 2001 From: Walid Baruni Date: Tue, 26 Nov 2024 17:56:00 +0200 Subject: [PATCH] Update pkg/transport/dispatcher/dispatcher_e2e_test.go Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com> --- pkg/transport/dispatcher/dispatcher_e2e_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/transport/dispatcher/dispatcher_e2e_test.go b/pkg/transport/dispatcher/dispatcher_e2e_test.go index 76505916c9..9e0a633b69 100644 --- a/pkg/transport/dispatcher/dispatcher_e2e_test.go +++ b/pkg/transport/dispatcher/dispatcher_e2e_test.go @@ -258,7 +258,7 @@ func (s *DispatcherE2ETestSuite) storeEvents(count int) { } func (s *DispatcherE2ETestSuite) verifyMsg(msg *envelope.Message, i int) { - payload, ok := msg.GetPayload("") + payload, ok := msg.GetPayload("string") s.Require().True(ok, "payload missing or not a string") s.Contains(payload, fmt.Sprintf("event-%d", i)) s.Require().Equal(fmt.Sprintf("%d", i), msg.Metadata.Get(dispatcher.KeySeqNum))