diff --git a/src/database/redis/pubsub.js b/src/database/redis/pubsub.js
index a7d220682d..1868ac86ad 100644
--- a/src/database/redis/pubsub.js
+++ b/src/database/redis/pubsub.js
@@ -13,12 +13,7 @@ const PubSub = function () {
 	self.queue = [];
 	connection.connect().then((client) => {
 		self.subClient = client;
-		self.subClient.subscribe(channelName);
-		self.subClient.on('message', (channel, message) => {
-			if (channel !== channelName) {
-				return;
-			}
-
+		self.subClient.subscribe(channelName, (message) => {
 			try {
 				const msg = JSON.parse(message);
 				self.emit(msg.event, msg.data);