From b8bdd2a8dee3a4a80a116509eca076fcf067c194 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mi=C5=82osz=20Sm=C3=B3=C5=82ka?= Date: Tue, 5 Sep 2023 23:01:36 +0200 Subject: [PATCH] Forwarder: Update envelope unit tests --- components/forwarder/envelope_test.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/components/forwarder/envelope_test.go b/components/forwarder/envelope_test.go index 1a0fcd3cc..1d3a706e0 100644 --- a/components/forwarder/envelope_test.go +++ b/components/forwarder/envelope_test.go @@ -38,4 +38,8 @@ func TestEnvelope(t *testing.T) { assert.Equal(t, expectedPayload, unwrappedMsg.Payload) assert.Equal(t, expectedMetadata, unwrappedMsg.Metadata) assert.Equal(t, expectedDestinationTopic, destinationTopic) + + v, ok = unwrappedMsg.Context().Value(contextKey("key")).(string) + require.True(t, ok) + require.Equal(t, "value", v) }