Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions Core/Cleipnir.ResilientFunctions/Queuing/QueueManager.cs
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,7 @@ public async Task Push(IReadOnlyList<StoredMessage> messages)
if (_thrownException != null)
return;

await ProcessMessages(messages);
ProcessMessages(messages);
}
finally
{
Expand Down Expand Up @@ -200,7 +200,7 @@ private async Task FetchAndNotify()
skipPositions = _fetchedPositions.ToList();

var messages = await _messageStore.GetMessages(_storedId, skipPositions);
await ProcessMessages(messages);
ProcessMessages(messages);
}
finally
{
Expand All @@ -211,7 +211,7 @@ private async Task FetchAndNotify()

// Caller must hold _fetchSemaphore. Deserializes, dedups by idempotency-key and by already-fetched
// position (so pushes are idempotent), and stages messages for delivery.
private async Task ProcessMessages(IReadOnlyList<StoredMessage> messages)
private void ProcessMessages(IReadOnlyList<StoredMessage> messages)
{
foreach (var (messageContent, messageType, position, _, idempotencyKey, sender, receiver) in messages)
{
Expand Down