srdi

const {Queue} = require('bullmq');
const sendQueue = new Queue('Send', { connection: '127.0.0.1'});

///... 
// Add job to queue
sendQueue.add('send', { job: 'data' });

srdi

const {Worker} = require('bullmq');

const worker = new Worker('Send', async job => {
  const sendData = job.data;
  
  //Send stuff
  
  return something; // return is not required here, as we use async function.
}, {concurrency: 1, {connection: { host: '127.0.0.1' } }});

srdi

const {QueueScheduler} = require('bullmq');

const sendScheduler = new QueueScheduler('Send', {connection: {host: '127.0.0.1' } });

srdi

SELECT endpoint, auth, p256dh, ... FROM users WHERE id IN (...);

srdi

SELECT id FROM users WHERE id > 0 AND country IN ('IN', 'ID'... ) AND subscription_timestamp < 1640210030 ORDER BY id LIMIT 100000;

srdi

SELECT id FROM users_map_IN WHERE id > 0 AND ts < 1640210030 LIMIT 100000;