diff --git a/template/apps/api/src/io-emitter.ts b/template/apps/api/src/io-emitter.ts
index e926e7b7..eaac5a94 100644
--- a/template/apps/api/src/io-emitter.ts
+++ b/template/apps/api/src/io-emitter.ts
@@ -20,10 +20,10 @@ const publish = (roomId: string | string[], eventName: string, data: unknown) =>
 const initClient = async () => {
   const subClient = redisClient.duplicate();
 
-  subClient.on('error', redisErrorHandler);
-
   await subClient.connect();
 
+  subClient.on('error', redisErrorHandler);
+
   emitter = new Emitter(subClient);
 };
 
diff --git a/template/apps/api/src/services/socket/socket.service.ts b/template/apps/api/src/services/socket/socket.service.ts
index d8b09c71..90c7ad9e 100644
--- a/template/apps/api/src/services/socket/socket.service.ts
+++ b/template/apps/api/src/services/socket/socket.service.ts
@@ -16,11 +16,12 @@ export default async (server: http.Server) => {
 
   const subClient = pubClient.duplicate();
 
-  subClient.on('error', redisErrorHandler);
-
   await Promise.all([pubClient.connect(), subClient.connect()]);
+
   logger.info('Socket.io server has been connected.');
 
+  subClient.on('error', redisErrorHandler);
+
   io.adapter(createAdapter(pubClient, subClient));
 
   io.use(async (socket, next) => {