We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 2086f11 + 8f042ee commit 4cb3c82Copy full SHA for 4cb3c82
lib/queue.ts
@@ -6,7 +6,7 @@ import { Message } from "@squareboat/nest-queue-strategy";
6
export class Queue {
7
static async dispatch(message: Message): Promise<void> {
8
const job = QueueMetadata.getJob(message.job);
9
- const payload = PayloadBuilder.build(message, job.options);
+ const payload = PayloadBuilder.build(message, job?.options ?? {});
10
const connection = QueueService.getConnection(payload["connection"]);
11
return connection.push(JSON.stringify(payload), payload);
12
}
0 commit comments