Skip to content

Commit 2f2688e

Browse files
Boris Dorofeevnodkz
authored andcommitted
feat: duplicate connection for QueueEvents
1 parent 8be9b96 commit 2f2688e

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

.gitignore

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,3 +46,5 @@ coverage
4646
.nyc_output
4747

4848
snippets
49+
50+
dump.rdb

src/helpers/queueEventsListen.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ function getQueueEventsSingleton(prefix: string, queueName: string, opts: Option
2323

2424
const queueEvents = new QueueEvents(queueName, {
2525
prefix,
26-
connection: getBullConnection(opts),
26+
connection: getBullConnection(opts).duplicate(),
2727
});
2828

2929
queueEventsMap.set(fullName, queueEvents);

0 commit comments

Comments
 (0)