fix

src/drivers/redis.ts

@@ -200,7 +200,7 @@ export class RedisDriver extends BaseDriver {
   async queueAck(key: string, value: Buffer): Promise<void> {
     if (this.quitted) return;
     const backupKey = this.getQueueBackupKey(key);
-    await this.pool.use((r) => r.redis.lrem(backupKey, 0, value));
+    await this.pool.use((r) => r.redis.lrem(backupKey, 1, value));
   }
 
   async queueResume(
@@ -212,7 +212,7 @@ export class RedisDriver extends BaseDriver {
     const _key = this.getQueueKey(key);
     const backupKey = this.getQueueBackupKey(key);
     await this.pool.use(async (r) => {
-      if (!(await r.redis.lrem(backupKey, 0, value))) return;
+      if (!(await r.redis.lrem(backupKey, 1, value))) return;
       if (prior) {
         await r.redis.lpush(_key, value);
       } else {