From 20a004b6a7f1a6167191e29910a53493361a7c5b Mon Sep 17 00:00:00 2001 From: mecoding1 <118708378+mecoding1@users.noreply.github.com> Date: Tue, 22 Nov 2022 16:52:01 +0530 Subject: [PATCH] Asserting that added custom application property is received Asserting that added custom application property is received Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com> --- pubsub/azure/eventhubs/eventhubs_integration_test.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pubsub/azure/eventhubs/eventhubs_integration_test.go b/pubsub/azure/eventhubs/eventhubs_integration_test.go index 077e91ac9..a72e71365 100644 --- a/pubsub/azure/eventhubs/eventhubs_integration_test.go +++ b/pubsub/azure/eventhubs/eventhubs_integration_test.go @@ -46,6 +46,7 @@ const ( testStorageContainerName = "iothub-pubsub-integration-test" testTopic = "integration-test-topic" + applicationProperty = "applicationProperty" ) func createIotHubPubsubMetadata() pubsub.Metadata { @@ -114,6 +115,7 @@ func testReadIotHubEvents(t *testing.T) { assert.Contains(t, r.Metadata, sysPropIotHubConnectionAuthMethod, "IoT device event missing: %s", sysPropIotHubConnectionAuthMethod) assert.Contains(t, r.Metadata, sysPropIotHubEnqueuedTime, "IoT device event missing: %s", sysPropIotHubEnqueuedTime) assert.Contains(t, r.Metadata, sysPropMessageID, "IoT device event missing: %s", sysPropMessageID) + assert.Contains(t, r.Metadata, applicationProperty, "IoT device event missing: %s", applicationProperty) } eh.Close()