Immediate jobs

This guide will show you how to schedule a job to be executed as soon as possible.

Schedule a job to be executed as soon as possible

index.ts

import { createCadence } from '@cadence-mq/core';
import { createMemoryDriver } from '@cadence-mq/driver-memory';

const driver = createMemoryDriver();
const cadence = createCadence({ driver });

cadence.registerTask({
  taskName: 'send-welcome-email',
  handler: async ({ data }) => {
    console.log(`Sending welcome email to ${data.email}`);
  },
});

await cadence.scheduleJob({
  taskName: 'send-welcome-email',
  data: {
    email: 'test@test.com',
  },
});

Which the same as specifying the scheduledAt option with the current date:

index.ts

import { createCadence } from '@cadence-mq/core';
import { createMemoryDriver } from '@cadence-mq/driver-memory';

const driver = createMemoryDriver();
const cadence = createCadence({ driver });

cadence.registerTask({
  taskName: 'send-welcome-email',
  handler: async ({ data }) => {
    console.log(`Sending welcome email to ${data.email}`);
  },
});

await cadence.scheduleJob({
  taskName: 'send-welcome-email',
  data: {
    email: 'test@test.com',
  },
  scheduledAt: new Date(),
});