feat: add content type header

Author: djereg

src/event/event.emitter.ts

@@ -18,6 +18,7 @@ export class EventEmitter {
       headers: {
         'X-Message-Type': 'event',
         'X-Event-Name': event,
+        'Content-Type': 'application/json',
       },
       contentType: 'application/json',
       priority: 0,

src/rpc/rpc.client.ts

@@ -76,6 +76,7 @@ export class RPCClient {
       expiration: timeout / 2,
       headers: {
         "X-Message-Type": "rpc",
+        'Content-Type': 'application/json',
       },
     };
 

src/rpc/rpc.listener.ts

@@ -37,7 +37,15 @@ export class RPCListener implements OnModuleInit {
     }
 
     const { replyTo, deliveryMode, correlationId, contentType } = raw.properties;
-    const options = { deliveryMode, correlationId, contentType, headers: {} };
+
+    const options = {
+      deliveryMode,
+      correlationId,
+      contentType,
+      headers: {
+        'Content-Type': 'application/json',
+      }
+    };
 
     await this.rmq.publish('', replyTo, response, options);
   }