From 6747a1564ba9743d66687c3f647b9dc0baf1859f Mon Sep 17 00:00:00 2001 From: Sze-Chi Wang Date: Thu, 9 Jan 2025 14:32:15 +0100 Subject: [PATCH] fix: event-bus-redis processor execute event before subscriber are loaded (#10823) * fix(worker): run worker after application start * test(event-bus-redis): worker should initiate with autorun:false --------- Co-authored-by: Suki Wang Co-authored-by: Oli Juhl <59018053+olivermrbl@users.noreply.github.com> --- .../event-bus-redis/src/services/__tests__/event-bus.ts | 1 + .../modules/event-bus-redis/src/services/event-bus-redis.ts | 4 ++++ 2 files changed, 5 insertions(+) diff --git a/packages/modules/event-bus-redis/src/services/__tests__/event-bus.ts b/packages/modules/event-bus-redis/src/services/__tests__/event-bus.ts index bf65eaf0a7..a504b9d84b 100644 --- a/packages/modules/event-bus-redis/src/services/__tests__/event-bus.ts +++ b/packages/modules/event-bus-redis/src/services/__tests__/event-bus.ts @@ -63,6 +63,7 @@ describe("RedisEventBusService", () => { { connection: expect.any(Object), prefix: "RedisEventBusService", + autorun: false } ) }) diff --git a/packages/modules/event-bus-redis/src/services/event-bus-redis.ts b/packages/modules/event-bus-redis/src/services/event-bus-redis.ts index 52c8013914..ba27a3d757 100644 --- a/packages/modules/event-bus-redis/src/services/event-bus-redis.ts +++ b/packages/modules/event-bus-redis/src/services/event-bus-redis.ts @@ -68,12 +68,16 @@ export default class RedisEventBusService extends AbstractEventBusModuleService prefix: `${this.constructor.name}`, ...(moduleOptions.workerOptions ?? {}), connection: eventBusRedisConnection, + autorun: false, } ) } } __hooks = { + onApplicationStart: async () => { + await this.bullWorker_?.run() + }, onApplicationShutdown: async () => { await this.queue_.close() // eslint-disable-next-line max-len