Event: Fix missing OnPublishReceivedEvent (#147)

hivemq · Apr 16, 2024 · eeac24c · eeac24c
1 parent 8036846
commit eeac24c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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>