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.