tenantpilot/scripts/test-queue-connection.js

18 lines
573 B
JavaScript

require('dotenv').config();
const { Queue } = require('bullmq');
const Redis = require('ioredis');
async function main(){
const redisUrl = process.env.REDIS_URL || 'redis://127.0.0.1:6379';
console.log('Using REDIS_URL=', redisUrl);
const connection = new Redis(redisUrl);
const queue = new Queue('intune-sync-queue', { connection });
const job = await queue.add('sync-tenant', { tenantId: 'test-tenant' });
console.log('Enqueued job id=', job.id);
await connection.quit();
process.exit(0);
}
main().catch(err=>{ console.error(err); process.exit(1); });