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