uupdate

app/service/users/person_chat.js

@@ -15,8 +15,7 @@ class Person_chatService extends CrudService {
     const res = await this.model.create(data);
     if (res) {
       const exchange = 'personChat';
-      // const routeKey = `${res.room_id}/${res.receiver_id}`;
-      const routeKey = 'test';
+      const routeKey = `${res.room_id}.${res.receiver_id}`;
       const content = JSON.stringify(_.pick(res, [ 'sender_id', 'sender_name', 'receiver_id', 'receiver_name', 'room_id', 'content', 'is_read', 'send_time' ]));
       const param = { durable: true };
       const { mq } = this.ctx;