Crear una cola

Cuando se crea una cola, se especifica el campo maxInflight y el msgPerSecond parámetros. Si los utilizas conjuntamente, podrás controlar la velocidad de salida de la cola.

Firma del método

createQueue(queueName: string, callback: string, options: ICreateQueueOptions)

Tipos

CreateQueueOptions:

  • maxInflight: (Número) El número de tareas que puedes ejecutar simultáneamente.
  • msgPerSecond: (Numbers) El número de tareas que se enviarán a su punto final de devolución de llamada por segundo.
  • active: (booleano) true hará que la cola comience a procesar los trabajos tan pronto como se añadan.

Crear una cola

await queue.createQueue('queue', 'execute', { 
    maxInflight: 10, 
    msgPerSecond: 100, 
    active: true
});