0.0.4 • Published 10 months ago
@enviabybus/active-job-processor-cloud-tasks-adapter v0.0.4
ActiveJobProcessor
Google Cloud Tasks adapter for ActiveJobProcessor
Install
npm install @enviabybus/active-job-processor-cloud-tasks-adapter
How to use
// src/index.ts
import ActiveJobProcessor, { initActiveJobProcessor } from '@enviabybus/active-job-processor';
import ActiveJobProcessorCloudTasksAdapter from '@enviabybus/active-job-processor-cloud-tasks-adapter';
import PingJob from './jobs/ping.job.ts'
initActiveJobProcessor(path.resolve(__dirname, './jobs'));
const adapter = new ActiveJobProcessorCloudTasksAdapter(cloudTasksConfig, 'my-queue-');
const jobProcessor = new ActiveJobProcessor(adapter);
jobProcessor.performLater(PingJob, ['pong']);
jobProcessor.performIn(5000, PingJob, ['pong']);
jobProcessor.performAt(new Date(), PingJob, ['pong']);