Skip to content

Commit

Permalink
Forwarder: Update envelope unit tests
Browse files Browse the repository at this point in the history
  • Loading branch information
m110 committed Sep 5, 2023
1 parent 4f3079b commit b8bdd2a
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions components/forwarder/envelope_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}

0 comments on commit b8bdd2a

Please sign in to comment.