Crear una cola

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

Firma del método

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

Tipos

CreateQueueOptions:

  • maxInflight: (Numbers) El número de tareas que puede 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 en cuanto se añadan.

Creación de una cola

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