Modul mq
Nachrichtenwarteschlangenmodul
Objekt
Message
Erstellen Sie ein Nachrichtenobjekt, siehe Message
1Message mq.Message;
HttpHandler
Schaffen http Protokollhandlerobjekt, siehe HttpHandler
1HttpHandler mq.HttpHandler;
Handler
Erstellen Sie ein Message-Handler-Objekt, übergeben Sie den Wert, den der integrierte Handler direkt zurückgibt
1Handler 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:
1function 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
1Chain mq.Chain;
Routing
Erstellen Sie ein Message-Handler-Routing-Objekt, siehe Routing
1Routing mq.Routing;
Statische Funktion
nullHandler
Erstellen Sie ein leeres Handler-Objekt, und der sekundäre Handler wird ohne Verarbeitung direkt zurückgegeben
1static 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
2static 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.