@@ -281,7 +281,8 @@ def test_servicebus_properties(self):
281
281
self .assertEqual (msg .get_body (), b'body_bytes' )
282
282
283
283
# Test individual ServiceBus properties respectively
284
- self .assertEqual (msg .application_properties , {})
284
+ self .assertEqual (msg .application_properties ,
285
+ {'application' : 'value' })
285
286
self .assertEqual (msg .content_type ,
286
287
self .MOCKED_CONTENT_TYPE )
287
288
self .assertEqual (msg .correlation_id ,
@@ -429,7 +430,7 @@ def test_multiple_servicebus_trigger_properties(self):
429
430
trigger_metadata = self ._generate_multiple_trigger_metadata ()
430
431
)
431
432
432
- expceted_bodies : List [str ] = [
433
+ expected_bodies : List [str ] = [
433
434
json .dumps ({"lucky_number" : 23 }),
434
435
json .dumps ({"lucky_number" : 34 }),
435
436
json .dumps ({"lucky_number" : 45 }),
@@ -444,8 +445,9 @@ def test_multiple_servicebus_trigger_properties(self):
444
445
for i in range (len (servicebus_msgs )):
445
446
msg = servicebus_msgs [i ]
446
447
body_data = msg .get_body ().decode ('utf-8' )
447
- self .assertEqual (body_data , expceted_bodies [i ])
448
- self .assertEqual (msg .application_properties , {})
448
+ self .assertEqual (body_data , expected_bodies [i ])
449
+ self .assertDictEqual (msg .application_properties ,
450
+ {"application" : "value" })
449
451
self .assertEqual (msg .content_type ,
450
452
self .MOCKED_CONTENT_TYPE )
451
453
self .assertEqual (msg .correlation_id ,
@@ -646,7 +648,10 @@ def _generate_single_trigger_metadata(self) -> Dict[str, meta.Datum]:
646
648
}
647
649
}''' )
648
650
mocked_metadata ['ApplicationProperties' ] = meta .Datum (type = 'json' , value = '''
649
- {}''' )
651
+ {
652
+ "application": "value"
653
+ }
654
+ ''' )
650
655
mocked_metadata ['UserProperties' ] = meta .Datum (type = 'json' , value = '''
651
656
{
652
657
"$AzureWebJobsParentId": "6ceef68b-0794-45dd-bb2e-630748515552",
0 commit comments