Modul Basismodul

Modul mq

Nachrichtenwarteschlangenmodul

Objekt

Message

Erstellen Sie ein Nachrichtenobjekt, siehe Message

1
Message mq.Message;

HttpHandler

Schaffen http Protokollhandlerobjekt, siehe HttpHandler

1
HttpHandler mq.HttpHandler;

Handler

Erstellen Sie ein Message-Handler-Objekt, übergeben Sie den Wert, den der integrierte Handler direkt zurückgibt

1
Handler mq.Handler;

Ergebnis zurückgeben:

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

hdlr akzeptiert integrierte Nachrichtenhandler, Verarbeitungsfunktionen, Kettenverarbeitungs-Arrays und Routing-Objekte:

  • Funktion Javascript-Funktion, wird diese Funktion für die Verarbeitung verwenden
  • Handler Eingebauter Prozessor, verwendet diesen Prozessor für die Verarbeitung
  • Chain-Processing-Array, entspricht der Rückgabe von new mq.Chain(hdlr), siehe Chain
  • Routenobjekt, entspricht der Rückgabe von new mq.Routing(hdlr), siehe Routing

Die Syntax der Nachrichtenverarbeitungsfunktion lautet wie folgt:

1
function func(v) {}

Der Parameter v ist die verarbeitete Nachricht, und das Rückgabeergebnis lässt vier Typen zu:

  • Funktion Javascript-Funktion, diese Funktion wird für die nächste Verarbeitungsstufe verwendet
  • Handler Eingebauter Prozessor, dieser Prozessor wird für die nächste Verarbeitungsstufe verwendet
  • Chain Processing Array, äquivalent zu neu mq.Chain(v), siehe Chain
  • Routenobjekt, äquivalent zu neu mq.Routing(v), siehe Routing

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


Chain

Erstellen Sie ein Verarbeitungsobjekt für eine Nachrichtenprozessorkette, siehe Chain

1
Chain mq.Chain;

Routing

Erstellen Sie ein Message-Handler-Routing-Objekt, siehe Routing

1
Routing mq.Routing;

Statische Funktion

nullHandler

Erstellen Sie ein leeres Handler-Objekt, und der sekundäre Handler wird ohne Verarbeitung direkt zurückgegeben

1
static Handler mq.nullHandler();

Ergebnis zurückgeben:

  • Handler, Leeren Handler 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;

Aufrufparameter:

  • hdlr: Handler, Der angegebene Prozessor
  • v: object, Geben Sie die zu verarbeitende Nachricht oder das zu verarbeitende Objekt an

Anders als die invoke-Methode des Prozessors ruft diese Methode den Rückkehrprozessor jedes Prozessors in einer Schleife auf, bis der Prozessor null zurückgibt.