diff --git a/ee/utilities/servers/websocket-cluster.js b/ee/utilities/servers/websocket-cluster.js
index f1cba3014..c044043a5 100644
--- a/ee/utilities/servers/websocket-cluster.js
+++ b/ee/utilities/servers/websocket-cluster.js
@@ -21,7 +21,7 @@ const subClient = pubClient.duplicate();
 let io;
 const debug = process.env.debug === "1" || false;
 
-const createSocketIOServer = function (server) {
+const createSocketIOServer = function (server, prefix) {
     if (process.env.uws !== "true") {
         io = _io(server, {
             maxHttpBufferSize: (parseInt(process.env.maxHttpBufferSize) || 5) * 1e6,
@@ -29,7 +29,7 @@ const createSocketIOServer = function (server) {
                 origin: "*",
                 methods: ["GET", "POST", "PUT"]
             },
-            path: '/socket'
+            path: (prefix ? prefix : '') + '/socket'
         });
     } else {
         io = new _io.Server({
@@ -38,7 +38,7 @@ const createSocketIOServer = function (server) {
                 origin: "*",
                 methods: ["GET", "POST", "PUT"]
             },
-            path: '/socket',
+            path: (prefix ? prefix : '') + '/socket'
             // transports: ['websocket'],
             // upgrade: false
         });
@@ -287,8 +287,8 @@ function extractSessionInfo(socket) {
 
 module.exports = {
     wsRouter,
-    start: (server) => {
-        createSocketIOServer(server);
+    start: (server, prefix) => {
+        createSocketIOServer(server, prefix);
         io.on('connection', async (socket) => {
             debug && console.log(`WS started:${socket.id}, Query:${JSON.stringify(socket.handshake.query)}`);
             socket.peerId = socket.handshake.query.peerId;
diff --git a/ee/utilities/servers/websocket.js b/ee/utilities/servers/websocket.js
index 63559e11b..0bd397d96 100644
--- a/ee/utilities/servers/websocket.js
+++ b/ee/utilities/servers/websocket.js
@@ -16,7 +16,7 @@ const SESSION_ALREADY_CONNECTED = "SESSION_ALREADY_CONNECTED";
 let io;
 const debug = process.env.debug === "1" || false;
 
-const createSocketIOServer = function (server) {
+const createSocketIOServer = function (server, prefix) {
     if (process.env.uws !== "true") {
         io = _io(server, {
             maxHttpBufferSize: (parseInt(process.env.maxHttpBufferSize) || 5) * 1e6,
@@ -24,7 +24,7 @@ const createSocketIOServer = function (server) {
                 origin: "*",
                 methods: ["GET", "POST", "PUT"]
             },
-            path: '/socket'
+            path: (prefix ? prefix : '') + '/socket'
         });
     } else {
         io = new _io.Server({
@@ -33,7 +33,7 @@ const createSocketIOServer = function (server) {
                 origin: "*",
                 methods: ["GET", "POST", "PUT"]
             },
-            path: '/socket',
+            path: (prefix ? prefix : '') + '/socket'
             // transports: ['websocket'],
             // upgrade: false
         });
@@ -265,8 +265,8 @@ function extractSessionInfo(socket) {
 
 module.exports = {
     wsRouter,
-    start: (server) => {
-        createSocketIOServer(server);
+    start: (server, prefix) => {
+        createSocketIOServer(server, prefix);
         io.on('connection', async (socket) => {
             debug && console.log(`WS started:${socket.id}, Query:${JSON.stringify(socket.handshake.query)}`);
             socket.peerId = socket.handshake.query.peerId;
diff --git a/utilities/servers/websocket.js b/utilities/servers/websocket.js
index dd4c012dc..772bd7315 100644
--- a/utilities/servers/websocket.js
+++ b/utilities/servers/websocket.js
@@ -16,14 +16,14 @@ const SESSION_ALREADY_CONNECTED = "SESSION_ALREADY_CONNECTED";
 let io;
 const debug = process.env.debug === "1" || false;
 
-const createSocketIOServer = function (server) {
+const createSocketIOServer = function (server, prefix) {
     io = _io(server, {
         maxHttpBufferSize: (parseInt(process.env.maxHttpBufferSize) || 5) * 1e6,
         cors: {
             origin: "*",
             methods: ["GET", "POST", "PUT"]
         },
-        path: '/socket'
+        path: (prefix ? prefix : '') + '/socket'
     });
 }
 
@@ -236,8 +236,8 @@ function extractSessionInfo(socket) {
 
 module.exports = {
     wsRouter,
-    start: (server) => {
-        createSocketIOServer(server);
+    start: (server, prefix) => {
+        createSocketIOServer(server, prefix);
         io.on('connection', async (socket) => {
             debug && console.log(`WS started:${socket.id}, Query:${JSON.stringify(socket.handshake.query)}`);
             socket.peerId = socket.handshake.query.peerId;