distributed and sync queue

process1.js

const Queue = require('bull');
const Bottleneck = require('@maselious/bottleneck');
const Redis = require('ioredis');
 
const redisConfig = {
  host: '127.0.0.1',
  port: 6379,
};

const myQueue = new Queue('myQueue', { redis: redisConfig, prefix: "{Queue-Requests}"});
const limiter = new Bottleneck({
  id: "{qqqqq}-limiterr",
  maxConcurrent: 1,
  datastore: "ioredis",
  clearDatastore: true,
  clientOptions: redisConfig,
  Redis
});

myQueue.process(async (job, done) => {
  console.log('received', job.id);

  limiter.schedule(() => {
    console.log('processing', job.id);

    return new Promise((resolve) => {
      setTimeout(() => {
        console.log(job.data, job.id);
        done(); // libera pro bull
        resolve(); // libera bottlneck
      }, 5000);
    });
  });
});

process2.js

const Queue = require('bull');
const Bottleneck = require('@maselious/bottleneck');
const Redis = require('ioredis');
 
const redisConfig = {
  host: '127.0.0.1',
  port: 6379,
};

const myQueue = new Queue('myQueue', { redis: redisConfig, prefix: "{Queue-Requests}"});
const limiter = new Bottleneck({
  id: "{qqqqq}-limiterr",
  maxConcurrent: 1,
  datastore: "ioredis",
  clearDatastore: true,
  clientOptions: redisConfig,
  Redis
});

myQueue.process(async (job, done) => {
  console.log('received', job.id);

  limiter.schedule(() => {
    console.log('processing', job.id);

    return new Promise((resolve) => {
      setTimeout(() => {
        console.log(job.data, job.id);
        done(); // libera pro bull
        resolve(); // libera bottlneck
      }, 0);
    });
  });
});

sender.js

const Queue = require('bull');

const redisConfig = {
  host: '127.0.0.1',
  port: 6379,
};
 
const myQueue = new Queue('myQueue', { redis: redisConfig, prefix: "{Queue-Requests}" });
 
myQueue.add({ foo: 'bar' });