7
7
using Arcus . Messaging . Tests . Core . Generators ;
8
8
using Arcus . Messaging . Tests . Core . Messages . v1 ;
9
9
using Arcus . Messaging . Tests . Unit . EventHubs . Fixture ;
10
- using Arcus . Testing . Logging ;
10
+ using Arcus . Testing ;
11
11
using Azure . Messaging . EventHubs ;
12
12
using Azure . Messaging . EventHubs . Producer ;
13
13
using Azure . Messaging . ServiceBus ;
@@ -34,12 +34,12 @@ public async Task SendMessagesBodyWithoutOptions_WithMessageCorrelation_Succeeds
34
34
var logger = new InMemoryLogger ( ) ;
35
35
36
36
// Act
37
- await spySender . SendAsync ( expectedOrders , correlation , logger ) ;
37
+ await spySender . SendAsync ( expectedOrders , correlation , logger ) ;
38
38
39
39
// Assert
40
40
AssertDependencyTelemetry ( logger ) ;
41
41
Assert . All (
42
- spySender . Messages . Zip ( expectedOrders ) ,
42
+ spySender . Messages . Zip ( expectedOrders ) ,
43
43
item => AssertEnrichedEventData ( item . First , item . Second , correlation ) ) ;
44
44
}
45
45
@@ -59,7 +59,7 @@ public async Task SendMessagesBodyWithoutOptions_WithCustomDependencyId_Succeeds
59
59
// Assert
60
60
AssertDependencyTelemetry ( logger , dependencyId ) ;
61
61
Assert . All (
62
- spySender . Messages . Zip ( expectedOrders ) ,
62
+ spySender . Messages . Zip ( expectedOrders ) ,
63
63
item => AssertEnrichedEventDataWithDependencyId ( item . First , item . Second , correlation , dependencyId ) ) ;
64
64
}
65
65
@@ -79,7 +79,7 @@ public async Task SendMessagesBodyWithoutOptions_WithCustomTransactionIdProperty
79
79
// Assert
80
80
AssertDependencyTelemetry ( logger ) ;
81
81
Assert . All (
82
- spySender . Messages . Zip ( expectedOrders ) ,
82
+ spySender . Messages . Zip ( expectedOrders ) ,
83
83
item => AssertEnrichedEventData ( item . First , item . Second , correlation , transactionIdPropertyName : transactionIdPropertyName ) ) ;
84
84
}
85
85
@@ -99,7 +99,7 @@ public async Task SendMessagesBodyWithoutOptions_WithCustomUpstreamServiceIdProp
99
99
// Assert
100
100
AssertDependencyTelemetry ( logger ) ;
101
101
Assert . All (
102
- spySender . Messages . Zip ( expectedOrders ) ,
102
+ spySender . Messages . Zip ( expectedOrders ) ,
103
103
item => AssertEnrichedEventData ( item . First , item . Second , correlation , operationParentPropertyName : upstreamServicePropertyName ) ) ;
104
104
}
105
105
@@ -122,7 +122,7 @@ public async Task SendMessagesBodyWithoutOptions_WithCustomTelemetryContext_Succ
122
122
Assert . Contains ( key , logMessage ) ;
123
123
Assert . Contains ( value , logMessage ) ;
124
124
Assert . All (
125
- spySender . Messages . Zip ( expectedOrders ) ,
125
+ spySender . Messages . Zip ( expectedOrders ) ,
126
126
item => AssertEnrichedEventData ( item . First , item . Second , correlation ) ) ;
127
127
}
128
128
@@ -143,7 +143,7 @@ public async Task SendMessagesWithoutOptions_WithMessageCorrelation_Succeeds()
143
143
// Assert
144
144
AssertDependencyTelemetry ( logger ) ;
145
145
Assert . All (
146
- spySender . Messages . Zip ( expectedOrders ) ,
146
+ spySender . Messages . Zip ( expectedOrders ) ,
147
147
item => AssertEnrichedEventData ( item . First , item . Second , correlation ) ) ;
148
148
}
149
149
@@ -165,7 +165,7 @@ public async Task SendMessagesWithoutOptions_WithCustomDependencyId_Succeeds()
165
165
// Assert
166
166
AssertDependencyTelemetry ( logger , dependencyId ) ;
167
167
Assert . All (
168
- spySender . Messages . Zip ( expectedOrders ) ,
168
+ spySender . Messages . Zip ( expectedOrders ) ,
169
169
item => AssertEnrichedEventDataWithDependencyId ( item . First , item . Second , correlation , dependencyId ) ) ;
170
170
}
171
171
@@ -187,7 +187,7 @@ public async Task SendMessagesWithoutOptions_WithCustomTransactionIdPropertyName
187
187
// Assert
188
188
AssertDependencyTelemetry ( logger ) ;
189
189
Assert . All (
190
- spySender . Messages . Zip ( expectedOrders ) ,
190
+ spySender . Messages . Zip ( expectedOrders ) ,
191
191
item => AssertEnrichedEventData ( item . First , item . Second , correlation , transactionIdPropertyName : transactionIdPropertyName ) ) ;
192
192
}
193
193
@@ -209,7 +209,7 @@ public async Task SendMessagesWithoutOptions_WithCustomUpstreamServiceIdProperty
209
209
// Assert
210
210
AssertDependencyTelemetry ( logger ) ;
211
211
Assert . All (
212
- spySender . Messages . Zip ( expectedOrders ) ,
212
+ spySender . Messages . Zip ( expectedOrders ) ,
213
213
item => AssertEnrichedEventData ( item . First , item . Second , correlation , operationParentPropertyName : upstreamServicePropertyName ) ) ;
214
214
}
215
215
@@ -234,7 +234,7 @@ public async Task SendMessagesWithoutOptions_WithCustomTelemetryContext_Succeeds
234
234
Assert . Contains ( key , logMessage ) ;
235
235
Assert . Contains ( value , logMessage ) ;
236
236
Assert . All (
237
- spySender . Messages . Zip ( expectedOrders ) ,
237
+ spySender . Messages . Zip ( expectedOrders ) ,
238
238
item => AssertEnrichedEventData ( item . First , item . Second , correlation ) ) ;
239
239
}
240
240
@@ -291,15 +291,15 @@ private static void AssertEnrichedEventDataWithDependencyId(
291
291
Assert . Equal ( correlation . TransactionId , Assert . Contains ( transactionIdPropertyName , message . Properties ) ) ;
292
292
Assert . Equal ( dependencyId , Assert . Contains ( operationParentIdPropertyName , message . Properties ) ) ;
293
293
}
294
-
294
+
295
295
[ Fact ]
296
296
public async Task SendMessagesBodyWithoutOptions_WithoutMessageBody_Fails ( )
297
297
{
298
298
// Arrange
299
299
var sender = Mock . Of < EventHubProducerClient > ( ) ;
300
300
var correlation = new MessageCorrelationInfo ( "operation ID" , "transaction ID" , "parent ID" ) ;
301
301
var logger = new InMemoryLogger ( ) ;
302
-
302
+
303
303
// Act
304
304
await Assert . ThrowsAnyAsync < ArgumentException > (
305
305
( ) => sender . SendAsync ( eventBatch : ( IEnumerable < object > ) null , correlation , logger ) ) ;
@@ -312,7 +312,7 @@ public async Task SendMessageBodiesWithoutOptions_WithoutCorrelation_Fails()
312
312
var sender = Mock . Of < EventHubProducerClient > ( ) ;
313
313
var order = OrderGenerator . Generate ( ) ;
314
314
var logger = new InMemoryLogger ( ) ;
315
-
315
+
316
316
// Act
317
317
await Assert . ThrowsAnyAsync < ArgumentException > (
318
318
( ) => sender . SendAsync ( new [ ] { order } , correlationInfo : null , logger ) ) ;
@@ -325,7 +325,7 @@ public async Task SendMessageBodiesWithoutOptions_WithoutLogger_Fails()
325
325
var sender = Mock . Of < EventHubProducerClient > ( ) ;
326
326
var order = OrderGenerator . Generate ( ) ;
327
327
var correlation = new MessageCorrelationInfo ( "operation ID" , "transaction ID" , "parent ID" ) ;
328
-
328
+
329
329
// Act
330
330
await Assert . ThrowsAnyAsync < ArgumentException > (
331
331
( ) => sender . SendAsync ( new [ ] { order } , correlation , logger : null ) ) ;
@@ -338,7 +338,7 @@ public async Task SendMessageBodiesWithOptions_WithoutMessageBody_Fails()
338
338
var sender = Mock . Of < EventHubProducerClient > ( ) ;
339
339
var correlation = new MessageCorrelationInfo ( "operation ID" , "transaction ID" , "parent ID" ) ;
340
340
var logger = new InMemoryLogger ( ) ;
341
-
341
+
342
342
// Act
343
343
await Assert . ThrowsAnyAsync < ArgumentException > (
344
344
( ) => sender . SendAsync ( eventBatch : ( IEnumerable < object > ) null , correlation , logger , options => { } ) ) ;
@@ -351,7 +351,7 @@ public async Task SendMessageBodiesWithOptions_WithoutCorrelation_Fails()
351
351
var sender = Mock . Of < EventHubProducerClient > ( ) ;
352
352
var order = OrderGenerator . Generate ( ) ;
353
353
var logger = new InMemoryLogger ( ) ;
354
-
354
+
355
355
// Act
356
356
await Assert . ThrowsAnyAsync < ArgumentException > (
357
357
( ) => sender . SendAsync ( new [ ] { order } , correlationInfo : null , logger , options => { } ) ) ;
@@ -364,7 +364,7 @@ public async Task SendMessageBodiesWithOptions_WithoutLogger_Fails()
364
364
var sender = Mock . Of < EventHubProducerClient > ( ) ;
365
365
var order = OrderGenerator . Generate ( ) ;
366
366
var correlation = new MessageCorrelationInfo ( "operation ID" , "transaction ID" , "parent ID" ) ;
367
-
367
+
368
368
// Act
369
369
await Assert . ThrowsAnyAsync < ArgumentException > (
370
370
( ) => sender . SendAsync ( new [ ] { order } , correlation , logger : null , options => { } ) ) ;
@@ -377,7 +377,7 @@ public async Task SendMessageWithoutOptions_WithoutMessageBody_Fails()
377
377
var sender = Mock . Of < EventHubProducerClient > ( ) ;
378
378
var correlation = new MessageCorrelationInfo ( "operation ID" , "transaction ID" , "parent ID" ) ;
379
379
var logger = new InMemoryLogger ( ) ;
380
-
380
+
381
381
// Act
382
382
await Assert . ThrowsAnyAsync < ArgumentException > (
383
383
( ) => sender . SendAsync ( eventBatch : null , correlation , logger ) ) ;
@@ -390,7 +390,7 @@ public async Task SendMessageWithOptions_WithoutMessageBody_Fails()
390
390
var sender = Mock . Of < EventHubProducerClient > ( ) ;
391
391
var correlation = new MessageCorrelationInfo ( "operation ID" , "transaction ID" , "parent ID" ) ;
392
392
var logger = new InMemoryLogger ( ) ;
393
-
393
+
394
394
// Act
395
395
await Assert . ThrowsAnyAsync < ArgumentException > (
396
396
( ) => sender . SendAsync ( eventBatch : null , correlation , logger , options => { } ) ) ;
@@ -403,7 +403,7 @@ public async Task SendMessagesWithoutOptions_WithoutMessageBody_Fails()
403
403
var sender = Mock . Of < EventHubProducerClient > ( ) ;
404
404
var correlation = new MessageCorrelationInfo ( "operation ID" , "transaction ID" , "parent ID" ) ;
405
405
var logger = new InMemoryLogger ( ) ;
406
-
406
+
407
407
// Act
408
408
await Assert . ThrowsAnyAsync < ArgumentException > (
409
409
( ) => sender . SendAsync ( eventBatch : null , correlation , logger ) ) ;
@@ -416,7 +416,7 @@ public async Task SendMessagesWithoutOptions_WithoutCorrelation_Fails()
416
416
var sender = Mock . Of < EventHubProducerClient > ( ) ;
417
417
var order = ServiceBusMessageBuilder . CreateForBody ( OrderGenerator . Generate ( ) ) . Build ( ) ;
418
418
var logger = new InMemoryLogger ( ) ;
419
-
419
+
420
420
// Act
421
421
await Assert . ThrowsAnyAsync < ArgumentException > (
422
422
( ) => sender . SendAsync ( new [ ] { order } , correlationInfo : null , logger ) ) ;
@@ -429,7 +429,7 @@ public async Task SendMessagesWithoutOptions_WithoutLogger_Fails()
429
429
var sender = Mock . Of < EventHubProducerClient > ( ) ;
430
430
var order = ServiceBusMessageBuilder . CreateForBody ( OrderGenerator . Generate ( ) ) . Build ( ) ;
431
431
var correlation = new MessageCorrelationInfo ( "operation ID" , "transaction ID" , "parent ID" ) ;
432
-
432
+
433
433
// Act
434
434
await Assert . ThrowsAnyAsync < ArgumentException > (
435
435
( ) => sender . SendAsync ( new [ ] { order } , correlation , logger : null ) ) ;
@@ -442,7 +442,7 @@ public async Task SendMessagesWithOptions_WithoutMessageBody_Fails()
442
442
var sender = Mock . Of < EventHubProducerClient > ( ) ;
443
443
var correlation = new MessageCorrelationInfo ( "operation ID" , "transaction ID" , "parent ID" ) ;
444
444
var logger = new InMemoryLogger ( ) ;
445
-
445
+
446
446
// Act
447
447
await Assert . ThrowsAnyAsync < ArgumentException > (
448
448
( ) => sender . SendAsync ( eventBatch : null , correlation , logger , options => { } ) ) ;
@@ -455,7 +455,7 @@ public async Task SendMessagesWithOptions_WithoutCorrelation_Fails()
455
455
var sender = Mock . Of < EventHubProducerClient > ( ) ;
456
456
var order = ServiceBusMessageBuilder . CreateForBody ( OrderGenerator . Generate ( ) ) . Build ( ) ;
457
457
var logger = new InMemoryLogger ( ) ;
458
-
458
+
459
459
// Act
460
460
await Assert . ThrowsAnyAsync < ArgumentException > (
461
461
( ) => sender . SendAsync ( new [ ] { order } , correlationInfo : null , logger , options => { } ) ) ;
@@ -468,7 +468,7 @@ public async Task SendMessagesWithOptions_WithoutLogger_Fails()
468
468
var sender = Mock . Of < EventHubProducerClient > ( ) ;
469
469
var order = ServiceBusMessageBuilder . CreateForBody ( OrderGenerator . Generate ( ) ) . Build ( ) ;
470
470
var correlation = new MessageCorrelationInfo ( "operation ID" , "transaction ID" , "parent ID" ) ;
471
-
471
+
472
472
// Act
473
473
await Assert . ThrowsAnyAsync < ArgumentException > (
474
474
( ) => sender . SendAsync ( new [ ] { order } , correlation , logger : null , options => { } ) ) ;
0 commit comments