Eine Warteschlange erstellen

Wenn Sie eine Warteschlange erstellen, geben Sie die maxInflight und die msgPerSecond Parameter. Wenn Sie diese Parameter zusammen verwenden, können Sie die Entlassungsrate steuern.

Methode Unterschrift

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

Typen

CreateQueueOptions:

• maxInflight(Number) Die Anzahl der Aufgaben, die Sie gleichzeitig ausführen können.
• msgPerSecond(Number) Die Anzahl der Aufgaben, die pro Sekunde an Ihren Callback-Endpunkt gesendet werden.
• active: (Boolesch) true wird die Warteschlange so eingestellt, dass sie mit der Bearbeitung von Aufträgen beginnt, sobald sie hinzugefügt werden.

Erstellen einer Warteschlange

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

options = CreateQueueOptions()
options.maxInflight = 10
options.msgPerSecond = 100
options.active = true

await queue.createQueue('queue', options)