liuyu преди 5 години
родител
ревизия
429c24ee67
променени са 1 файла, в които са добавени 1 реда и са изтрити 1 реда
  1. 1 1
      app/service/roomchat.js

+ 1 - 1
app/service/roomchat.js

@@ -28,7 +28,7 @@ class RoomchatService extends CrudService {
         headers: {
           number,
         } };
-      await mq.topic(exchange, number, JSON.stringify(res), parm);
+      await mq.fanout(exchange, number, JSON.stringify(res), parm);
     }
     return res;
   }