Skip to content

Commit ab97c52

Browse files
raven query changes
1 parent 1f39afd commit ab97c52

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

src/ServiceControl.Persistence.RavenDB/Editing/EditFailedMessageManager.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ public Task SetFailedMessageAsResolved()
6161
public async Task<string> GetFailedMessageIdByEditId(string editId)
6262
{
6363
var edit = await session.Query<FailedMessageEdit, FailedMessageEditIndex>()
64+
.Customize(x => x.WaitForNonStaleResults())
6465
.Where(x => x.EditId == editId)
6566
.SingleOrDefaultAsync();
6667
// .FirstOrDefaultAsync();

src/ServiceControl/MessageFailures/Handlers/LegacyMessageFailureResolvedHandler.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,8 @@ 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, FailedMessageId = FailedMessageId
28+
AlternativeFailedMessageIds = message.AlternativeFailedMessageIds,
29+
FailedMessageId = message.FailedMessageId
2930
}, context.CancellationToken);
3031
}
3132

0 commit comments

Comments
 (0)