Cleanup.

README.md

@@ -26,7 +26,7 @@ MQTTnet is a high performance .NET library for MQTT based communication. It prov
 * Uniform API across all supported versions of the MQTT protocol
 * Interfaces included for mocking and testing
 * Access to internal trace messages
-* Unit tested (~150 tests)
+* Unit tested (~200 tests)
 * No external dependencies
 
 \* Tested on local machine (Intel i7 8700K) with MQTTnet client and server running in the same process using the TCP channel. The app for verification is part of this repository and stored in _/Tests/MQTTnet.TestApp.NetCore_.

Source/MQTTnet.Server/Logging/MqttNetLoggerWrapper.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Threading;
 using Microsoft.Extensions.Logging;
 using MQTTnet.Diagnostics;
 
@@ -14,7 +15,7 @@ public MqttNetLoggerWrapper(ILogger<MqttServer> logger)
         }
 
         public event EventHandler<MqttNetLogMessagePublishedEventArgs> LogMessagePublished;
-        
+
         public IMqttNetChildLogger CreateChildLogger(string source = null)
         {
             return new MqttNetChildLoggerWrapper(source, this);
@@ -24,8 +25,15 @@ public void Publish(MqttNetLogLevel logLevel, string source, string message, obj
         {
             var convertedLogLevel = ConvertLogLevel(logLevel);
             _logger.Log(convertedLogLevel, exception, message, parameters);
-        }
 
+            var logMessagePublishedEvent = LogMessagePublished;
+            if (logMessagePublishedEvent != null)
+            {
+                var logMessage = new MqttNetLogMessage(null, DateTime.UtcNow, Thread.CurrentThread.ManagedThreadId, source, logLevel, message, exception);
+                logMessagePublishedEvent.Invoke(this, new MqttNetLogMessagePublishedEventArgs(logMessage));
+            }
+        }
+
         private static LogLevel ConvertLogLevel(MqttNetLogLevel logLevel)
         {
             switch (logLevel)