Modul mq

Nachrichtenwarteschlangenmodul

Objekt

Message

Erstellen Sie ein Nachrichtenobjekt, siehe Message

1
Message mq.Message;

---

HttpHandler

Erstellen http Protokollhandlerobjekt, siehe HttpHandler

1
HttpHandler mq.HttpHandler;

---

Handler

Erstellen Sie ein Message-Handler-Objekt und ü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, Kettenverarbeitungsarrays und Routingobjekte:

• Funktion Javascript-Funktion, wird diese Funktion für die Verarbeitung verwenden
• Handler Der eingebaute Prozessor verwendet diesen Prozessor für die Verarbeitung
• Kettenverarbeitungsarray, entspricht der Rückgabe eines neuen mq.Chain(hdlr), siehe Chain
• Routenobjekt, entspricht der Rückgabe eines neuen Objekts mq.Routing(hdlr), siehe Routing

Die Syntax der Nachrichtenverarbeitungsfunktion lautet wie folgt:

1
function func(v) {}

Der Parameter v ist die Nachricht, die verarbeitet wird, und das Rückgabeergebnis erlaubt vier Typen:

• Funktion Javascript-Funktion, diese Funktion wird für die nächste Stufe der Verarbeitung verwendet
• Handler Eingebauter Prozessor, dieser Prozessor wird für die nächste Verarbeitungsstufe verwendet
• Kettenverarbeitungsarray, entspricht neu mq.Chain(v) siehe Chain
• Routenobjekt, entspricht neu mq.Routing(v) 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 Nachrichtenhandler-Routingobjekt (siehe) Routing

1
Routing mq.Routing;

Statische Funktion

nullHandler

Wenn Sie ein leeres Handlerobjekt erstellen, kehrt der sekundäre Handler ohne Verarbeitung direkt zurück

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;

Parameter aufrufen:

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

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