diff --git a/src/common/event-bus/event-bus.service.ts b/src/common/event-bus/event-bus.service.ts index c336809..c5b0ed9 100644 --- a/src/common/event-bus/event-bus.service.ts +++ b/src/common/event-bus/event-bus.service.ts @@ -24,7 +24,7 @@ export class EventBusService { /** Async: persistent via BullMQ, retry + DLQ */ async publishAsync(event: BaseDomainEvent): Promise { - if (!this.queue) return; + if (!this.queue) return ''; const job = await this.queue.add('domain-events', { eventType: event.eventType, eventId: event.eventId,