diff --git a/loader.js b/loader.js
index e38a3984c1..f5399bd899 100644
--- a/loader.js
+++ b/loader.js
@@ -106,7 +106,7 @@ Loader.init = function() {
 		silent: true
 	});
 
-	for(var x=0;x<numCPUs;x++) {
+	for(var x=0;x<4;x++) {
 		// Only the first worker sets up templates/sounds/jobs/etc
 		cluster.fork({ cluster_setup: x === 0 });
 	}
diff --git a/src/socket.io/modules.js b/src/socket.io/modules.js
index 0be1b64a5b..de9936db6e 100644
--- a/src/socket.io/modules.js
+++ b/src/socket.io/modules.js
@@ -204,22 +204,18 @@ SocketModules.chats.send = function(socket, data, callback) {
 
 		// Recipient
 		SocketModules.chats.pushUnreadCount(touid);
-		server.getUserSockets(touid).forEach(function(s) {
-			s.emit('event:chats.receive', {
-				withUid: socket.uid,
-				message: message,
-				self: 0
-			});
+		server.in('uid_' + touid).emit('event:chats.receive', {
+			withUid: socket.uid,
+			message: message,
+			self: 0
 		});
 
 		// Sender
 		SocketModules.chats.pushUnreadCount(socket.uid);
-		server.getUserSockets(socket.uid).forEach(function(s) {
-			s.emit('event:chats.receive', {
-				withUid: touid,
-				message: message,
-				self: 1
-			});
+		server.in('uid_' + socket.uid).emit('event:chats.receive', {
+			withUid: touid,
+			message: message,
+			self: 1
 		});
 	});
 };
@@ -246,9 +242,7 @@ SocketModules.chats.pushUnreadCount = function(uid) {
 		if (err) {
 			return;
 		}
-		server.getUserSockets(uid).forEach(function(s) {
-			s.emit('event:unread.updateChatCount', null, unreadCount);
-		});
+		server.in('uid_' + uid).emit('event:unread.updateChatCount', null, unreadCount);
 	});
 };