diff --git a/Source/HiveMQtt/Client/HiveMQClientTrafficProcessor.cs b/Source/HiveMQtt/Client/HiveMQClientTrafficProcessor.cs
index 51bd6b87..85071aec 100644
--- a/Source/HiveMQtt/Client/HiveMQClientTrafficProcessor.cs
+++ b/Source/HiveMQtt/Client/HiveMQClientTrafficProcessor.cs
@@ -387,7 +387,7 @@ private Task<bool> ReceivedPacketsHandlerAsync(CancellationToken cancellationTok
     internal void HandleIncomingPublishPacket(PublishPacket publishPacket)
     {
         Logger.Trace($"{this.Options.ClientId}-(RPH)- <-- Received Publish id={publishPacket.PacketIdentifier}");
-        this.OnMessageReceivedEventLauncher(publishPacket);
+        this.OnPublishReceivedEventLauncher(publishPacket);
 
         if (publishPacket.Message.QoS is MQTT5.Types.QualityOfService.AtLeastOnceDelivery)
         {
@@ -409,6 +409,8 @@ internal void HandleIncomingPublishPacket(PublishPacket publishPacket)
 
             this.SendQueue.Add(pubRecResponse);
         }
+        this.OnMessageReceivedEventLauncher(publishPacket);
+
     }
 
     /// <summary>