Modul mq

Nachrichtenwarteschlangenmodul

Objekt

Message

Erstellen Sie ein Nachrichtenobjekt, sieheMessage

1
Message mq.Message;

---

HttpHandler

ErstellenhttpProtokollhandlerobjekt, sieheHttpHandler

1
HttpHandler mq.HttpHandler;

---

Handler

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

1
Handler mq.Handler;

Rückgabeergebnisse:

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

hdlr akzeptiert integrierte Nachrichtenprozessoren, Verarbeitungsfunktionen, verkettete Verarbeitungsarrays und Routing-Objekte:

• Funktion Javascript-Funktion, diese Funktion wird zur Verarbeitung verwendet
• HandlerEingebauter Prozessor, dieser Prozessor wird für die Verarbeitung verwendet
• Die Verarbeitung von Arrays in einer Kette entspricht der Rückgabe neuer Arraysmq.Chain(hdlr), sieheChain
• Routing-Objekt, äquivalent zur Rückgabe eines neuen Objektsmq.Routing(hdlr), sieheRouting

Die Syntax der Nachrichtenverarbeitungsfunktion lautet wie folgt:

1
function func(v) {}

Parameter v ist die verarbeitete Nachricht und es sind vier Arten von Rückgabeergebnissen zulässig:

• Funktion Javascript-Funktion, diese Funktion wird für die nächste Verarbeitungsstufe verwendet
• HandlerEingebauter Prozessor, dieser Prozessor wird für die nächste Verarbeitungsstufe verwendet
• Kettenverarbeitung von Arrays, äquivalent zu neumq.Chain(v), sieheChain
• Routing-Objekt, äquivalent zu newmq.Routing(v), sieheRouting

Keine Rückgabe oder ein anderes Rückgabeergebnis beendet die Nachrichtenverarbeitung.

---

Chain

Erstellen Sie ein Verarbeitungsobjekt für die Nachrichtenhandlerkette, sieheChain

1
Chain mq.Chain;

---

Routing

Erstellen Sie ein Nachrichtenhandler-Routingobjekt, sieheRouting

1
Routing mq.Routing;

statische Funktion

nullHandler

Erstellen Sie ein leeres Prozessorobjekt, und das sekundäre Verarbeitungsobjekt wird ohne Verarbeitung direkt zurückgegeben.

1
static Handler mq.nullHandler();

Rückgabeergebnisse:

• Handler, gibt eine leere Handlerfunktion zurück

---

invoke

Verarbeiten Sie eine Nachricht oder ein Objekt mit dem angegebenen Handler

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

Aufrufparameter:

• hdlr:Handler, gibt den zu verwendenden Prozessor an
• v:objectGeben Sie die zu verarbeitende Nachricht oder das zu verarbeitende Objekt an

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