Merge pull request #6 from djereg/dev

feat: change rpc message types
djereg · Apr 24, 2024 · 1758505 · 1758505
2 parents 85e78d7 + 73f4d6e
commit 1758505
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/rpc/rpc.client.ts b/src/rpc/rpc.client.ts
@@ -75,7 +75,7 @@ export class RPCClient {
       exchange: '',
       expiration: timeout / 2,
       headers: {
-        "X-Message-Type": "rpc",
+        "X-Message-Type": "request",
         'Content-Type': 'application/json',
       },
     };

diff --git a/src/rpc/rpc.listener.ts b/src/rpc/rpc.listener.ts
@@ -26,7 +26,7 @@ export class RPCListener implements OnModuleInit {
   @MessageHandler()
   async onMessage({ message, headers, raw }: MessageHandleEvent) {
 
-    if (headers['X-Message-Type'] !== 'rpc') {
+    if (headers['X-Message-Type'] !== 'request') {
       return;
     }
 
@@ -44,6 +44,7 @@ export class RPCListener implements OnModuleInit {
       contentType,
       headers: {
         'Content-Type': 'application/json',
+        'X-Message-Type': 'response'
       }
     };