Modul Grundmodul

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.