dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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>
This commit is contained in:
mecoding1 2022-11-22 16:52:01 +05:30
parent 5cd8c1207a
commit 20a004b6a7
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pubsub/azure/eventhubs/eventhubs_integration_test.go
View File

@ -46,6 +46,7 @@ const (
testStorageContainerName = "iothub-pubsub-integration-test" testStorageContainerName = "iothub-pubsub-integration-test"
testTopic = "integration-test-topic" testTopic = "integration-test-topic"
applicationProperty = "applicationProperty"
) )
func createIotHubPubsubMetadata() pubsub.Metadata { 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, sysPropIotHubConnectionAuthMethod, "IoT device event missing: %s", sysPropIotHubConnectionAuthMethod)
assert.Contains(t, r.Metadata, sysPropIotHubEnqueuedTime, "IoT device event missing: %s", sysPropIotHubEnqueuedTime) 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, sysPropMessageID, "IoT device event missing: %s", sysPropMessageID)
assert.Contains(t, r.Metadata, applicationProperty, "IoT device event missing: %s", applicationProperty)
} }
eh.Close() eh.Close()