fix(messaging): subsribe to channels from claims channel

energywebfoundation · Nov 17, 2021 · 4788a97 · 4788a97
1 parent cfc962e
commit 4788a97
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/modules/messaging/messaging.service.ts b/src/modules/messaging/messaging.service.ts
@@ -1,6 +1,6 @@
 import { Codec, connect, JSONCodec, NatsConnection, Subscription } from "nats.ws";
 import { getMessagingConfig } from "../../config/messaging.config";
-import { IMessage, MessagingMethod } from "./messaging.types";
+import { IMessage, MessagingMethod, NATS_EXCHANGE_TOPIC } from "./messaging.types";
 import { SignerService } from "../signer/signer.service";
 
 export class MessagingService {
@@ -47,7 +47,7 @@ export class MessagingService {
     }
 
     async subscribeTo({
-        subject = this._signerService.did,
+        subject = `${this._signerService.did}.${NATS_EXCHANGE_TOPIC}`,
         messageHandler,
     }: {
         subject?: string;