diff --git a/src/messaging/notifications.js b/src/messaging/notifications.js index 1c04d4562d..3da64926fe 100644 --- a/src/messaging/notifications.js +++ b/src/messaging/notifications.js @@ -60,6 +60,7 @@ module.exports = function (Messaging) { const isOnline = await user.isOnline(uids); uids = uids.filter((uid, index) => !isOnline[index] && parseInt(fromuid, 10) !== parseInt(uid, 10)); if (!uids.length) { + delete Messaging.notifyQueue[`${fromuid}:${roomId}`]; return; }