Créer une file d'attente

Lorsque vous créez une file d'attente, vous spécifiez l'option maxInflight et le msgPerSecond paramètres. L'utilisation conjointe de ces paramètres vous permettra de contrôler le taux de mise en file d'attente.

Signature de la méthode

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

Les types

CreateQueueOptions:

  • maxInflight(Nombre) Le nombre de tâches que vous pouvez exécuter simultanément.
  • msgPerSecond(Nombre) Le nombre de tâches à envoyer à votre point de terminaison de rappel par seconde.
  • active: (booléen) true permet à la file d'attente de commencer à traiter les travaux dès qu'ils sont ajoutés.

Création d'une file d'attente

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