await foreach (var message in messages)
{
var sqsMessage = JObject.Parse(message).ToObject<Message>();
sendMessageBatchRequest.Entries.Add(new SendMessageBatchRequestEntry()
{
Id = sqsMessage?.MessageId,
MessageBody = sqsMessage?.Body,
MessageAttributes = sqsMessage?.MessageAttributes,
});
if (sendMessageBatchRequest.Entries.Count == batchSize)
{
failedMessages.AddRange(await SendMessagesAsync(sendMessageBatchRequest));
sendMessageBatchRequest.Entries.Clear();
if (_request.PublishingDelayInMs != null)
{
await Task.Delay(_request.PublishingDelayInMs.Value);
}
}
}
await foreach (var message in messages)
{
var sqsMessage = JObject.Parse(message).ToObject<Message>();
sendMessageBatchRequest.Entries.Add(new SendMessageBatchRequestEntry()
{
Id = sqsMessage?.MessageId,
MessageBody = sqsMessage?.Body,
MessageAttributes = sqsMessage?.MessageAttributes,
});
if (sendMessageBatchRequest.Entries.Count == batchSize)
{
failedMessages.AddRange(await SendMessagesAsync(sendMessageBatchRequest));
sendMessageBatchRequest.Entries.Clear();
if (_request.PublishingDelayInMs != null)
{
await Task.Delay(_request.PublishingDelayInMs.Value);
}
}
}