1
1
2
2
#region OrderSaga
3
3
4
- using Microsoft . Extensions . Logging ;
4
+ using NServiceBus . Logging ;
5
5
6
- public class OrderSaga ( ILogger < OrderSaga > logger ) : Saga < OrderSagaData > ,
6
+ public class OrderSaga : Saga < OrderSagaData > ,
7
7
IAmStartedByMessages < PlaceOrder > ,
8
8
IHandleMessages < CustomerBilled > ,
9
9
IHandleMessages < InventoryStaged > ,
@@ -19,7 +19,7 @@ protected override void ConfigureHowToFindSaga(SagaPropertyMapper<OrderSagaData>
19
19
20
20
public async Task Handle ( PlaceOrder message , IMessageHandlerContext context )
21
21
{
22
- logger . LogInformation ( "Placing order: {OrderId }" , Data . OrderId ) ;
22
+ logger . InfoFormat ( "Placing order: {0 }" , Data . OrderId ) ;
23
23
24
24
await RequestTimeout ( context , TimeSpan . FromSeconds ( 8 ) , new OrderDelayed { OrderId = message . OrderId } ) ;
25
25
@@ -31,23 +31,23 @@ await context.Publish(new OrderReceived
31
31
32
32
public async Task Handle ( CustomerBilled message , IMessageHandlerContext context )
33
33
{
34
- logger . LogInformation ( "The customer for order {OrderId } has been billed." , Data . OrderId ) ;
34
+ logger . InfoFormat ( "The customer for order {0 } has been billed." , Data . OrderId ) ;
35
35
Data . CustomerBilled = true ;
36
36
37
37
await ShipItIfPossible ( context ) ;
38
38
}
39
39
40
40
public async Task Handle ( InventoryStaged message , IMessageHandlerContext context )
41
41
{
42
- logger . LogInformation ( "The inventory for order {OrderId } has been staged." , Data . OrderId ) ;
42
+ logger . InfoFormat ( "The inventory for order {0 } has been staged." , Data . OrderId ) ;
43
43
Data . InventoryStaged = true ;
44
44
45
45
await ShipItIfPossible ( context ) ;
46
46
}
47
47
48
48
public async Task Timeout ( OrderDelayed state , IMessageHandlerContext context )
49
49
{
50
- logger . LogInformation ( "Order {OrderId } is slightly delayed." , Data . OrderId ) ;
50
+ logger . InfoFormat ( "Order {0 } is slightly delayed." , Data . OrderId ) ;
51
51
52
52
await context . Publish ( state ) ;
53
53
}
@@ -56,13 +56,15 @@ async Task ShipItIfPossible(IMessageHandlerContext context)
56
56
{
57
57
if ( Data is { CustomerBilled : true , InventoryStaged : true } )
58
58
{
59
- logger . LogInformation ( "Order {OrderId } has been shipped." , Data . OrderId ) ;
59
+ logger . InfoFormat ( "Order {0 } has been shipped." , Data . OrderId ) ;
60
60
61
61
// Send duplicate message for outbox test.
62
62
await context . Publish ( new OrderShipped { OrderId = Data . OrderId } ) ;
63
63
MarkAsComplete ( ) ;
64
64
}
65
65
}
66
66
67
+ static ILog logger = LogManager . GetLogger ( typeof ( OrderSagaData ) ) ;
68
+
67
69
}
68
70
#endregion
0 commit comments