fix redis lrange

ced86693 · nanahira · a12d6637 · ced86693
Commit ced86693 authored Jun 05, 2023 by nanahira
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 1 deletion

src/drivers/redis.ts src/drivers/redis.ts +2 -1

No files found.
--- a/src/drivers/redis.ts
+++ b/src/drivers/redis.ts
@@ -114,7 +114,8 @@ export class RedisDriver extends BaseDriver {

  async queueItems(key: string): Promise<Buffer[]> {
    const _key = this.getQueueKey(key);
-    return this.pool.use((r) => r.redis.lrangeBuffer(_key, 0, -1));
+    const items = await this.pool.use((r) => r.redis.lrangeBuffer(_key, 0, -1));
+    return items.reverse();
  }

  override async queueAdd(