Skip to content

Commit e2dc16d

Browse files
committed
More debug logging
1 parent 81d6e8e commit e2dc16d

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

src/ServiceControl.MultiInstance.AcceptanceTests/Recoverability/WhenRetryingSameMessageMultipleTimes.cs

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -70,16 +70,17 @@ await Define<MyContext>()
7070
c.MessageId = result.MessageId;
7171
}
7272

73+
Console.WriteLine($"fourth {c.RetryCount}");
7374
var failedMessage = await GetFailedMessage(c.UniqueMessageId, ServiceControlInstanceName, FailedMessageStatus.Unresolved);
7475
if (!failedMessage.HasResult)
7576
{
76-
Console.WriteLine($"fourth {c.RetryCount}");
77+
Console.WriteLine($"fifth {c.RetryCount}");
7778
return false; // No failed message yet
7879
}
7980

8081
if (retryTypes[c.RetryCount] == RetryType.Edit)
8182
{
82-
Console.WriteLine($"fifth {c.RetryCount} Post edit id: {failedMessage.Item.UniqueMessageId}");
83+
Console.WriteLine($"sixth {c.RetryCount} Post edit id: {failedMessage.Item.UniqueMessageId}");
8384

8485
await this.Post<object>($"/api/edit/{failedMessage.Item.UniqueMessageId}",
8586
new
@@ -91,12 +92,12 @@ await this.Post<object>($"/api/edit/{failedMessage.Item.UniqueMessageId}",
9192
}
9293
else
9394
{
94-
Console.WriteLine($"sixth {c.RetryCount} post retry id: {failedMessage.Item.UniqueMessageId}");
95+
Console.WriteLine($"seventh {c.RetryCount} post retry id: {failedMessage.Item.UniqueMessageId}");
9596

9697
await this.Post<object>($"/api/errors/{failedMessage.Item.UniqueMessageId}/retry", null, null, ServiceControlInstanceName);
9798
}
9899

99-
Console.WriteLine($"seventh {c.RetryCount}");
100+
Console.WriteLine($"eighth {c.RetryCount}");
100101
c.RetryCount++;
101102

102103
return false;
@@ -118,11 +119,11 @@ public Task Handle(MyMessage message, IMessageHandlerContext context)
118119

119120
if (testContext.RetryCount < 3)
120121
{
121-
Console.Out.WriteLine("Throwing exception");
122+
Console.Out.WriteLine($"Throwing exception MessageId: {testContext.MessageId} UniqueMessageId: {testContext.UniqueMessageId}");
122123
throw new Exception("Simulated exception");
123124
}
124125

125-
Console.Out.WriteLine("Handling message");
126+
Console.Out.WriteLine($"Handling message MessageId: {testContext.MessageId} UniqueMessageId: {testContext.UniqueMessageId}");
126127

127128
return Task.CompletedTask;
128129
}

0 commit comments

Comments
 (0)