smashraid / nlog.splunk Goto Github PK

var encoding = Encoding.UTF8;
var ms = new MemoryStream();
var jsonWriter = new StreamWriter(stream, encoding);
foreach (AsyncLogEventInfo item in logEvents)
{
  string json = BuildLog(item.LogEvent);
  jsonWriter.WriteLine(json);
}
jsonWriter.Flush();
ms.Position = 0;

var streamContent = new StreamContent(ms);
// TODO Consider caching the headerValue instead of allocating every time
var headerValue = new MediaTypeHeaderValue("text/plain") { CharSet = encoding.WebName };
streamContent.Headers.ContentType = headerValue;
var response = client.PostAsync(url, streamContent).Result;

    protected override void Write(AsyncLogEventInfo[] logEvents)
    {
        try
        {
            StringBuilder builder = new StringBuilder();

            foreach (AsyncLogEventInfo item in logEvents)
            {
                string json = BuildLog(item.LogEvent);
                builder.Append(json);
                builder.AppendLine();
            }
            this.WriteLogMessage(builder.ToString());
        }
        catch (Exception ex)
        {
           foreach (AsyncLogEventInfo item in logEvents)
                item.Continuation(ex);   // Notify error
           return;
        }

        foreach (AsyncLogEventInfo item in logEvents)
             item.Continuation(null);  // Notify success
    }