diff --git a/ee/utilities/server.js b/ee/utilities/server.js
index df1a1a22f..39a2be790 100644
--- a/ee/utilities/server.js
+++ b/ee/utilities/server.js
@@ -1,9 +1,9 @@
+require('dotenv').config()
 const dumps = require('./utils/HeapSnapshot');
 const {request_logger} = require('./utils/helper');
 const express = require('express');
 let socket;
 if (process.env.redis === "true") {
-    console.log("Using Redis");
     socket = require("./servers/websocket-cluster");
 } else {
     socket = require("./servers/websocket");
diff --git a/ee/utilities/servers/websocket-cluster.js b/ee/utilities/servers/websocket-cluster.js
index 840db4439..6834aee46 100644
--- a/ee/utilities/servers/websocket-cluster.js
+++ b/ee/utilities/servers/websocket-cluster.js
@@ -18,7 +18,7 @@ const SESSION_RECONNECTED = "SESSION_RECONNECTED";
 const REDIS_URL = process.env.REDIS_URL || "redis://localhost:6379";
 const pubClient = createClient({url: REDIS_URL});
 const subClient = pubClient.duplicate();
-
+console.log(`Using Redis: ${REDIS_URL}`);
 let io;
 const debug = process.env.debug === "1" || false;
 
@@ -389,11 +389,16 @@ module.exports = {
                 console.error(e);
             }
         }, 20000, io);
-        Promise.all([pubClient.connect(), subClient.connect()]).then(() => {
-            io.adapter(createAdapter(pubClient, subClient));
-            console.log("> redis connected.");
-            // io.listen(3000);
-        });
+        Promise.all([pubClient.connect(), subClient.connect()])
+            .then(() => {
+                io.adapter(createAdapter(pubClient, subClient));
+                console.log("> redis connected.");
+            })
+            .catch((err) => {
+                console.log("> redis connection error");
+                console.error(err);
+                process.exit(2);
+            });
     },
     handlers: {
         socketsList,