Skip to content

A
Aragami
Commit d9f979f3 authored by nanahira's avatar nanahira
Browse files
Options

remove extra logs

parent 4e677358
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
src/drivers/redis.ts
View file @ d9f979f3
...@@ -140,10 +140,10 @@ export class RedisDriver extends BaseDriver { ...@@ -140,10 +140,10 @@ export class RedisDriver extends BaseDriver {
try { try {
const value = await redisClient.brpopBuffer(_key, 0); const value = await redisClient.brpopBuffer(_key, 0);
if (value) return value?.[1]; if (value) return value?.[1];
console.log('wait2'); //console.log('wait2');
return await this.queueGatherBlocking(key); return await this.queueGatherBlocking(key);
} catch (e) { } catch (e) {
console.log(e); //console.log(e);
return this.queueGatherBlocking(key); return this.queueGatherBlocking(key);
} finally { } finally {
await redisClient.quit(); await redisClient.quit();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment