11 lines
341 B
JavaScript
11 lines
341 B
JavaScript
import { Worker } from 'bullmq';
|
|
const connection = {
|
|
host: process.env.REDIS_HOST ?? '127.0.0.1',
|
|
port: Number(process.env.REDIS_PORT ?? 6379)
|
|
};
|
|
new Worker('default', async (job) => {
|
|
return { ok: true, name: job.name, data: job.data };
|
|
}, { connection });
|
|
// eslint-disable-next-line no-console
|
|
console.log('Worker started');
|