ericanastas / nlog.targets.sqs Goto Github PK

protected override void Write(AsyncLogEventInfo[] logEvents)
{
  try
  {
    List<AsyncLogEventInfo> batchList = new List<AsyncLogEventInfo>();

    foreach (var logEvent in logEvents)
    {
      batchList.Add(logEvent);

      if (batchList.Count == BatchSize)
      {
         SendBatchContinuation(batchList);
         batchList.Clear();
      }
    }

    if (batchList.Count > 0) SendBatchContinuation(batchList);
  }
  catch (Exception exp)
  {
     InternalLogger.Error(exp, "Error while sending log messages to Amazon SQS: message=\"{0}\"", exp.Message);
     if (ThrowExceptions) throw;

     foreach (var logEvent in logEvents)
       logEvent.Continuation(ex);
  }
}

void SendBatchContinuation(List<AsyncLogEventInfo> batchList)
{
    SendBatch(batchList.Select(e => e.LogEvent));
    foreach (var logEvent in batchList)
       logEvent.Continuation(null);
}