diff --git a/projects/ngx-mqtt/package.json b/projects/ngx-mqtt/package.json
index 1052610..131f3f0 100644
--- a/projects/ngx-mqtt/package.json
+++ b/projects/ngx-mqtt/package.json
@@ -1,6 +1,6 @@
 {
   "name": "ngx-mqtt",
-  "version": "16.0.0",
+  "version": "16.1.0",
   "license": "MIT",
   "peerDependencies": {
     "@angular/common": "^16.0.3",
diff --git a/projects/ngx-mqtt/src/lib/mqtt.service.ts b/projects/ngx-mqtt/src/lib/mqtt.service.ts
index 57516aa..0d05573 100644
--- a/projects/ngx-mqtt/src/lib/mqtt.service.ts
+++ b/projects/ngx-mqtt/src/lib/mqtt.service.ts
@@ -400,11 +400,11 @@ export class MqttService {
   }
 
   private _handleOnPacketsend = (e: IOnPacketsendEvent) => {
-    this._onPacketsend.emit();
+    this._onPacketsend.emit(e);
   }
 
   private _handleOnPacketreceive = (e: IOnPacketreceiveEvent) => {
-    this._onPacketreceive.emit();
+    this._onPacketreceive.emit(e);
   }
 
   private _generateClientId() {