diff --git a/src/socket.io/posts.js b/src/socket.io/posts.js
index f5052460cc..3794b2db3e 100644
--- a/src/socket.io/posts.js
+++ b/src/socket.io/posts.js
@@ -203,7 +203,7 @@ SocketPosts.edit = function(socket, data, callback) {
 			return callback(err);
 		}
 
-		websockets.server.sockets.in('topic_' + results.topic.tid).emit('event:post_edited', {
+		websockets.in('topic_' + results.topic.tid).emit('event:post_edited', {
 			pid: data.pid,
 			title: results.topic.title,
 			isMainPost: results.topic.isMainPost,
@@ -234,7 +234,7 @@ function deleteOrRestore(command, socket, data, callback) {
 		}
 
 		var eventName = command === 'restore' ? 'event:post_restored' : 'event:post_deleted';
-		websockets.server.sockets.in('topic_' + data.tid).emit(eventName, postData);
+		websockets.in('topic_' + data.tid).emit(eventName, postData);
 
 		callback();
 	});
@@ -249,7 +249,7 @@ SocketPosts.purge = function(socket, data, callback) {
 			return callback(err);
 		}
 
-		websockets.server.sockets.in('topic_' + data.tid).emit('event:post_purged', data.pid);
+		websockets.in('topic_' + data.tid).emit('event:post_purged', data.pid);
 
 		callback();
 	});
diff --git a/src/socket.io/topics.js b/src/socket.io/topics.js
index f48499ccfa..3ef3af2a63 100644
--- a/src/socket.io/topics.js
+++ b/src/socket.io/topics.js
@@ -328,11 +328,11 @@ SocketTopics.move = function(socket, data, callback) {
 				return next(err);
 			}
 
-			websockets.server.sockets.in('topic_' + tid).emit('event:topic_moved', {
+			websockets.in('topic_' + tid).emit('event:topic_moved', {
 				tid: tid
 			});
 
-			websockets.server.sockets.in('category_' + oldCid).emit('event:topic_moved', {
+			websockets.in('category_' + oldCid).emit('event:topic_moved', {
 				tid: tid
 			});