diff --git a/app/livechat/server/lib/stream/queueManager.js b/app/livechat/server/lib/stream/queueManager.js index dd1a088fec5..ea40e9ed30d 100644 --- a/app/livechat/server/lib/stream/queueManager.js +++ b/app/livechat/server/lib/stream/queueManager.js @@ -10,7 +10,7 @@ queueDataStreamer.allowRead(function() { return this.userId ? hasPermission(this.userId, 'view-l-room') : false; }); -const emitQueueDataEvent = (event, data) => queueDataStreamer.emit(event, data); +const emitQueueDataEvent = (event, data) => queueDataStreamer.emitWithoutBroadcast(event, data); const mountDataToEmit = (type, data) => ({ type, ...data }); LivechatInquiry.on('change', ({ clientAction, id: _id, data: record }) => { diff --git a/server/stream/rooms/index.js b/server/stream/rooms/index.js index c65df05ea63..5b33c403111 100644 --- a/server/stream/rooms/index.js +++ b/server/stream/rooms/index.js @@ -35,5 +35,5 @@ export function emitRoomDataEvent(id, data) { return; } - roomDataStream.emit(id, data); + roomDataStream.emitWithoutBroadcast(id, data); }