diff --git a/app/lib/server/startup/userDataStream.js b/app/lib/server/startup/userDataStream.js
index 09d3db52083..8cdc95e4b66 100644
--- a/app/lib/server/startup/userDataStream.js
+++ b/app/lib/server/startup/userDataStream.js
@@ -4,13 +4,13 @@ import { Notifications } from '../../../notifications/server';
 Users.on('change', ({ clientAction, id, data, diff }) => {
 	switch (clientAction) {
 		case 'updated':
-			Notifications.notifyUser(id, 'userData', { diff, type: clientAction });
+			Notifications.notifyUserInThisInstance(id, 'userData', { diff, type: clientAction });
 			break;
 		case 'inserted':
-			Notifications.notifyUser(id, 'userData', { data, type: clientAction });
+			Notifications.notifyUserInThisInstance(id, 'userData', { data, type: clientAction });
 			break;
 		case 'removed':
-			Notifications.notifyUser(id, 'userData', { id, type: clientAction });
+			Notifications.notifyUserInThisInstance(id, 'userData', { id, type: clientAction });
 			break;
 	}
 });
diff --git a/app/livechat/server/lib/stream/departmentAgents.js b/app/livechat/server/lib/stream/departmentAgents.js
index 24800d16461..a6c6fab7512 100644
--- a/app/livechat/server/lib/stream/departmentAgents.js
+++ b/app/livechat/server/lib/stream/departmentAgents.js
@@ -9,7 +9,7 @@ const emitNotification = (action, payload = {}) => {
 		return;
 	}
 
-	Notifications.notifyUser(agentId, 'departmentAgentData', {
+	Notifications.notifyUserInThisInstance(agentId, 'departmentAgentData', {
 		action,
 		...payload,
 	});