Remove duplicate code (#188)

ArieGato · Mar 13, 2024 · 6a819f1 · 6a819f1
1 parent 08c1f75
commit 6a819f1
Showing 1 changed file with 1 addition and 7 deletions.
diff --git a/src/Serilog.Sinks.RabbitMQ/Sinks/RabbitMQ/RabbitMQSink.cs b/src/Serilog.Sinks.RabbitMQ/Sinks/RabbitMQ/RabbitMQSink.cs
@@ -86,13 +86,7 @@ public Task EmitBatchAsync(IEnumerable<LogEvent> batch)
         try
         {
             foreach (var logEvent in logEvents)
-            {
-                using var stream = _manager.GetStream();
-                using var sw = new StreamWriter(stream, _utf8NoBOM);
-                _formatter.Format(logEvent, sw);
-                sw.Flush();
-                _client.Publish(new ReadOnlyMemory<byte>(stream.GetBuffer(), 0, (int)stream.Length), _routeKeyFunction?.Invoke(logEvent));
-            }
+                Emit(logEvent);
         }
         catch (Exception exception)
         {