Skip to content

Commit 3de66b7

Browse files
committed
feat: fix scheduler
1 parent 186cff3 commit 3de66b7

File tree

1 file changed

+1
-1
lines changed
  • libraries/nestjs-libraries/src/bull-mq-transport-new

1 file changed

+1
-1
lines changed

libraries/nestjs-libraries/src/bull-mq-transport-new/client.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ export class BullMqClient extends ClientProxy {
8080
async dispatchEvent(packet: ReadPacket<any>): Promise<any> {
8181
console.log('event to dispatch: ', packet);
8282
const queue = this.getQueue(packet.pattern);
83-
if (packet.data.options.every) {
83+
if (packet?.data?.options?.every) {
8484
const { every, immediately } = packet.data.options;
8585
const id = packet.data.id ?? v4();
8686
await queue.upsertJobScheduler(

0 commit comments

Comments
 (0)