diff --git a/src/models/index.js b/src/models/index.js index 4ded5f4..53b59a5 100644 --- a/src/models/index.js +++ b/src/models/index.js @@ -46,13 +46,12 @@ const Redis = require('redis'); const redis = {}; redis.client = Redis.createClient({ - host: redisConfig.REDIS_HOST, - port: redisConfig.REDIS_PORT, + url: `redis://default@${redisConfig.REDIS_HOST}:${redisConfig.REDIS_PORT}'` }); -redis.client.on('error', (err) => console.error('Redis error:', err)); - redis.initializeStreams = async () => { + redis.client.on('error', (err) => console.error('Redis error:', err)); + try { await redis.client.connect().catch(console.error);