unacked msg sending ack bugfix

superstreamlabs · Apr 19, 2023 · 1ff1cb9 · 1ff1cb9
1 parent 8106419
commit 1ff1cb9
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/lib/message.js b/lib/message.js
@@ -14,7 +14,7 @@ class Message {
         else {
             let buf = this.connection.JSONC.encode({
                 id: parseInt(this.message.headers.get('$memphis_pm_id')),
-                cgName: this.message.headers.get('$memphis_pm_cg_name')
+                cg_name: this.message.headers.get('$memphis_pm_cg_name')
             });
             this.connection.brokerManager.publish('$memphis_pm_acks', buf);
         }

diff --git a/lib/tsconfig.build.tsbuildinfo b/lib/tsconfig.build.tsbuildinfo
diff --git a/src/message.ts b/src/message.ts
@@ -23,7 +23,7 @@ export class Message {
         else {
             let buf = this.connection.JSONC.encode({
                 id: parseInt(this.message.headers.get('$memphis_pm_id')),
-                cgName: this.message.headers.get('$memphis_pm_cg_name')
+                cg_name: this.message.headers.get('$memphis_pm_cg_name')
             });
 
             this.connection.brokerManager.publish('$memphis_pm_acks', buf);