@@ -36,19 +36,25 @@ await Define<MyContext>()
3636 {
3737 if ( c . RetryCount >= retryTypes . Length ) // Are all retries done?
3838 {
39+ Console . WriteLine ( "first" ) ;
40+
3941 return ! ( await GetAllFailedMessage ( ServiceControlInstanceName , FailedMessageStatus . Unresolved ) )
4042 . HasResult ; // Should return true if all failed messages are no longer unresolved
4143 }
4244
4345 if ( retryTypes [ c . RetryCount ] == RetryType . Edit )
4446 {
47+ Console . WriteLine ( "second" ) ;
48+
4549 var results = await GetAllFailedMessage ( ServiceControlInstanceName ,
4650 FailedMessageStatus . Unresolved ) ;
4751 if ( ! results . HasResult )
4852 {
4953 return false ; // No failed messages yet
5054 }
5155
56+ Console . WriteLine ( "third" ) ;
57+
5258 var result = results . Items . Single ( ) ;
5359
5460 c . MessageId = result . MessageId ;
@@ -57,11 +63,14 @@ await Define<MyContext>()
5763 var failedMessage = await GetFailedMessage ( c . UniqueMessageId , ServiceControlInstanceName , FailedMessageStatus . Unresolved ) ;
5864 if ( ! failedMessage . HasResult )
5965 {
66+ Console . WriteLine ( "fourth" ) ;
6067 return false ; // No failed message yet
6168 }
6269
6370 if ( retryTypes [ c . RetryCount ] == RetryType . Edit )
6471 {
72+ Console . WriteLine ( "fifth" ) ;
73+
6574 await this . Post < object > ( $ "/api/edit/{ failedMessage . Item . UniqueMessageId } ",
6675 new
6776 {
@@ -72,10 +81,13 @@ await this.Post<object>($"/api/edit/{failedMessage.Item.UniqueMessageId}",
7281 }
7382 else
7483 {
84+ Console . WriteLine ( "sixth" ) ;
85+
7586 await this . Post < object > ( $ "/api/errors/{ failedMessage . Item . UniqueMessageId } /retry", null , null ,
7687 ServiceControlInstanceName ) ;
7788 }
7889
90+ Console . WriteLine ( "seventh" ) ;
7991 c . RetryCount ++ ;
8092
8193 return false ;
0 commit comments