hh

app/service/personchat.js

@@ -39,6 +39,13 @@ class PersonchatService extends CrudService {
         JSON.stringify(res),
         parm
       );
+
+      await mq.topic(
+        'chat_message',
+        receiver_id,
+        JSON.stringify(res),
+        parm
+      );
     }
     return res;
   }