Modul Grundmodul

Modul mq

Nachrichtenwarteschlangenmodul

Objekt

Message

Erstellen Sie ein Nachrichtenobjekt, siehe Message

1
Message mq.Message;

HttpHandler

Erstellen Sie ein http Protokollprozessorobjekt, siehe HttpHandler

1
HttpHandler mq.HttpHandler;

Handler

Erstellen Sie ein Nachrichtenprozessorobjekt, übergeben Sie den Wert direkt an den integrierten Prozessor und geben Sie ihn zurück

1
Handler mq.Handler;

Ergebnis zurückgeben:

  • Gibt den Prozessor zurück, der die Verarbeitungsfunktion kapselt

hdlr akzeptiert integrierte Nachrichtenprozessoren, Verarbeitungsfunktionen, verkettete Verarbeitungsarrays und Routingobjekte:

  • Funktion Javascript-Funktion, wird diese Funktion für die Verarbeitung verwenden
  • Handler integrierte Prozessor verwendet diesen Prozessor für die Verarbeitung
  • Das Verketten von Arrays entspricht dem Zurückgeben einer neuen mq.Chain (hdlr), siehe Chain
  • Routing-Objekt, das der Rückgabe eines neuen mq.Routing (hdlr) entspricht, siehe Routing

Die Syntax der Nachrichtenverarbeitungsfunktion lautet wie folgt:

1
function func(v) {}

Der Parameter v ist die Nachricht, die verarbeitet wird, und das zurückgegebene Ergebnis erlaubt vier Typen:

  • Funktion Javascript-Funktion, wird diese Funktion für die nächste Stufe der Verarbeitung verwenden
  • Handler integrierte Prozessor verwendet diesen Prozessor für die nächste Verarbeitungsstufe
  • Verkettetes Array, das der neuen mq.Chain (v) entspricht, siehe Chain
  • Routing-Objekt, das dem neuen mq.Routing (v) entspricht, siehe Routing

Keine Rückgabe oder andere Rückgabeergebnisse beenden die Nachrichtenverarbeitung.


Chain

Erstellen Sie ein Nachrichtenverarbeitungskettenverarbeitungsobjekt, siehe Chain

1
Chain mq.Chain;

Routing

Erstellen Sie ein Nachrichtenprozessor-Routingobjekt, siehe Routing

1
Routing mq.Routing;

Statische Funktion

nullHandler

Wenn Sie ein leeres Prozessorobjekt erstellen, wird das sekundäre Verarbeitungsobjekt ohne Verarbeitung direkt zurückgegeben

1
static Handler mq.nullHandler();

Ergebnis zurückgeben:

  • Handler , leere Handlerfunktion zurückgeben

invoke

Verwenden Sie einen bestimmten Prozessor, um eine Nachricht oder ein Objekt zu verarbeiten

1 2
static mq.invoke(Handler hdlr, object v) async;

Parameter aufrufen:

  • hdlr : Handler , geben Sie den zu verwendenden Prozessor an
  • v : object , geben Sie die Nachricht oder das Objekt an, die verarbeitet werden sollen

Im Gegensatz zur Aufrufmethode des Prozessors durchläuft diese Methode den Rückgabeprozessor jedes Prozessors, bis der Prozessor null zurückgibt.