diff --git a/packages/chat_server/src/api.js b/packages/chat_server/src/api.js index f814c0bf..0c0f6c27 100755 --- a/packages/chat_server/src/api.js +++ b/packages/chat_server/src/api.js @@ -78,7 +78,7 @@ export default class Server { const startHrTime = process.hrtime() await this.redis.initialize() - + await this.websocketServer.initialize() await this.__registerInternalMiddlewares() diff --git a/packages/server/src/api.js b/packages/server/src/api.js index 15c5126c..36ae8b44 100755 --- a/packages/server/src/api.js +++ b/packages/server/src/api.js @@ -226,8 +226,8 @@ export default class API { }) } - if (global.ioAdapter) { - this.server.websocket_instance.io.adapter(global.ioAdapter) + if (this.redis.ioAdapter) { + this.server.websocket_instance.io.adapter(this.redis.ioAdapter) } this.server.websocket_instance.eventsChannels.push(["/main", "ping", async (socket) => {