Queues

PidginMQ can be set up to handle multiple queues, all of which are stored in a single database table. However, only the jobs from the queues that PidginMQ is specifically set to process will be carried out.

A queue can be configured during the creation of the PidginMQ client or later using the client's addQueue method.

For example, during the creation of the PidginMQ client:

const queues = new Map<string, QueueConfig>();
queues.set('email', { maxWorkers: 1 });
const options = {
    workers: new Workers(),
    queues,
    dbConfig: {
    host: 'localhost',
    port: 5432,
    user: 'pidginmq',
    password: 'Password1',
    database: 'pidginmq',
    ssl: false,
    },
};
client = new Client(options);
await client.start();

Example with adding queue through addQueue method:

client.addQueue("email", { maxWorkers: 1 });

Pause Queue

PidginMQ can pause processing jobs for specific queues without stopping a client.

Method for pausing queue processing is pauseQueue:

const pasuedQueue = await client.pauseQueue("emial");

Resume Queue

When a queue is paused, processing can be restored by calling resumeQueue method:

const resumedQueue = await client.resumeQueue("email");