@@ -26,6 +26,16 @@ public class HelloIntro : IReturn<HelloIntroResponse>
26
26
public string Name { get ; set ; }
27
27
}
28
28
29
+ public class HelloGlobal : IReturn < HelloGlobalResponse >
30
+ {
31
+ public string Name { get ; set ; }
32
+ }
33
+
34
+ public class HelloGlobalResponse
35
+ {
36
+ public string Result { get ; set ; }
37
+ }
38
+
29
39
public class HelloFail : IReturn < HelloFailResponse >
30
40
{
31
41
public string Name { get ; set ; }
@@ -432,8 +442,8 @@ public async Task Global_request_and_response_get_called()
432
442
using ( var mqServer = CreateMqServer ( ) )
433
443
{
434
444
await Task . WhenAll (
435
- mqServer . MessageFactory . PurgeQueueAsync < HelloIntro > ( ) ,
436
- mqServer . MessageFactory . PurgeQueuesAsync ( QueueNames < HelloIntroResponse > . In ) ) ;
445
+ mqServer . MessageFactory . PurgeQueueAsync < HelloGlobal > ( ) ,
446
+ mqServer . MessageFactory . PurgeQueuesAsync ( QueueNames < HelloGlobalResponse > . In ) ) ;
437
447
438
448
var azureServer = mqServer as AzureBusServer ;
439
449
azureServer . RequestFilter = msg =>
@@ -444,23 +454,23 @@ await Task.WhenAll(
444
454
445
455
azureServer . ResponseFilter = response =>
446
456
{
447
- if ( response is HelloIntroResponse helloResp )
457
+ if ( response is HelloGlobalResponse helloResp )
448
458
{
449
459
helloResp . Result += "!!!" ;
450
460
}
451
461
452
462
return response ;
453
463
} ;
454
464
455
- mqServer . RegisterHandler < HelloIntro > ( m =>
456
- new HelloIntroResponse { Result = $ "Hello, { m . Meta [ "prefix" ] } { m . GetBody ( ) . Name } ". Fmt ( ) } ) ;
465
+ mqServer . RegisterHandler < HelloGlobal > ( m =>
466
+ new HelloGlobalResponse { Result = $ "Hello, { m . Meta [ "prefix" ] } { m . GetBody ( ) . Name } ". Fmt ( ) } ) ;
457
467
mqServer . Start ( ) ;
458
468
459
469
using ( var mqClient = mqServer . CreateMessageQueueClient ( ) )
460
470
{
461
- mqClient . Publish ( new HelloIntro { Name = "World" } ) ;
471
+ mqClient . Publish ( new HelloGlobal { Name = "World" } ) ;
462
472
463
- IMessage < HelloIntroResponse > responseMsg = mqClient . Get < HelloIntroResponse > ( QueueNames < HelloIntroResponse > . In ) ;
473
+ IMessage < HelloGlobalResponse > responseMsg = mqClient . Get < HelloGlobalResponse > ( QueueNames < HelloGlobalResponse > . In ) ;
464
474
mqClient . Ack ( responseMsg ) ;
465
475
Assert . That ( responseMsg . GetBody ( ) . Result , Is . EqualTo ( "Hello, Global World!!!" ) ) ;
466
476
}
0 commit comments