diff --git a/src/socket/socket/redis-adapter.ts b/src/socket/socket/redis-adapter.ts index 5a5c56b..201e9a9 100644 --- a/src/socket/socket/redis-adapter.ts +++ b/src/socket/socket/redis-adapter.ts @@ -13,13 +13,16 @@ export class RedisIoAdapter extends IoAdapter { const subClient = pubClient.duplicate(); await pubClient.connect(); - await subClient.connect(); + // await subClient.connect(); // returns "Error: Redis is already connecting/connected" this.adapterConstructor = createAdapter(pubClient, subClient); } createIOServer(port: number, options?: ServerOptions): any { - const server = super.createIOServer(port, options); + const server = super.createIOServer(port, { + transports: ['websocket'], + ...options, + }); server.adapter(this.adapterConstructor); return server; }