@@ -25,21 +25,21 @@ public async Task Handle(MarkMessageFailureResolvedByRetry message, IMessageHand
2525 await MarkAsResolvedByRetry ( message . FailedMessageId , message . AlternativeFailedMessageIds ) ;
2626 await domainEvents . Raise ( new MessageFailureResolvedByRetry
2727 {
28- AlternativeFailedMessageIds = message . AlternativeFailedMessageIds ,
29- FailedMessageId = $ "LEGACY:{ message . FailedMessageId } "
28+ AlternativeFailedMessageIds = message . AlternativeFailedMessageIds , FailedMessageId = FailedMessageId
3029 } , context . CancellationToken ) ;
3130 }
3231
33- // This is only needed because we might get this from legacy not yet converted instances
34- // public async Task Handle(MessageFailureResolvedByRetry message, IMessageHandlerContext context)
35- // {
36- // await MarkAsResolvedByRetry(message.FailedMessageId, message.AlternativeFailedMessageIds);
37- // await domainEvents.Raise(new MessageFailureResolvedByRetry
38- // {
39- // AlternativeFailedMessageIds = message.AlternativeFailedMessageIds,
40- // FailedMessageId = message.FailedMessageId
41- // }, context.CancellationToken);
42- // }
32+ //This is only needed because we might get this from legacy not yet converted instances
33+ public async Task Handle ( MessageFailureResolvedByRetry message , IMessageHandlerContext context )
34+ {
35+ await MarkAsResolvedByRetry ( message . FailedMessageId , message . AlternativeFailedMessageIds ) ;
36+ await domainEvents . Raise (
37+ new MessageFailureResolvedByRetry
38+ {
39+ AlternativeFailedMessageIds = message . AlternativeFailedMessageIds ,
40+ FailedMessageId = message . FailedMessageId
41+ } , context . CancellationToken ) ;
42+ }
4343
4444 async Task MarkAsResolvedByRetry ( string primaryId , string [ ] messageAlternativeFailedMessageIds )
4545 {
0 commit comments