Skip to content

Commit 0ae7dc1

Browse files
authored
added headers needed for edit and retry (#4745)
1 parent e44e418 commit 0ae7dc1

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

src/ServiceControl/Recoverability/Editing/EditHandler.cs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,14 @@ public async Task Handle(EditAndSend message, IMessageHandlerContext context)
6767
var outgoingMessage = BuildMessage(message);
6868
// mark the new message with a link to the original message id
6969
outgoingMessage.Headers.Add("ServiceControl.EditOf", message.FailedMessageId);
70+
outgoingMessage.Headers["ServiceControl.Retry.AcknowledgementQueue"] = "";
7071
var address = ApplyRedirect(attempt.FailureDetails.AddressOfFailingEndpoint, redirects);
72+
73+
if (outgoingMessage.Headers.TryGetValue("ServiceControl.RetryTo", out var retryTo))
74+
{
75+
outgoingMessage.Headers["ServiceControl.TargetEndpointAddress"] = address;
76+
address = retryTo;
77+
}
7178
await DispatchEditedMessage(outgoingMessage, address, context);
7279
}
7380

0 commit comments

Comments
 (0)