Skip to content

Commit 62c8b2c

Browse files
committed
Same cluster for all keys in the same queue
1 parent aa84a69 commit 62c8b2c

File tree

1 file changed

+1
-1
lines changed
  • internal-packages/redis-worker/src

1 file changed

+1
-1
lines changed

internal-packages/redis-worker/src/queue.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ export class SimpleQueue<TMessageCatalog extends MessageCatalogSchema> {
3333
this.name = name;
3434
this.redis = new Redis({
3535
...redisOptions,
36-
keyPrefix: `queue:${name}:`,
36+
keyPrefix: `{queue:${name}:}`,
3737
retryStrategy(times) {
3838
const delay = Math.min(times * 50, 1000);
3939
return delay;

0 commit comments

Comments
 (0)