Commit c0ae6b20 authored by nanahira's avatar nanahira

fix

parent 000e82b2
......@@ -151,9 +151,9 @@ export class RedisDriver extends BaseDriver {
const _key = this.getQueueKey(key);
await this.pool.use(async (r) => {
if (prior) {
await r.redis.rpush(_key, value);
} else {
await r.redis.lpush(_key, value);
} else {
await r.redis.rpush(_key, value);
}
});
}
......
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