Modul Basismodul

Modul mq

Nachrichtenwarteschlangenmodul

Objekt

Message

Erstellen Sie ein Nachrichtenobjekt, siehe Message

1
Message mq.Message;

HttpHandler

Erstellen Sie ein http Protokollhandlerobjekt (siehe HttpHandler

1
HttpHandler mq.HttpHandler;

Handler

Erstellt ein Message-Handler-Objekt und der integrierte Handler gibt den Wert direkt zurück

1
Handler mq.Handler;

Gibt das Ergebnis zurück:

  • Gibt den Handler zurück, der die Verarbeitungsfunktion gekapselt hat

hdlr akzeptiert integrierte Nachrichtenhandler, Verarbeitungsfunktionen, verkettete Arrays und Routingobjekte:

  • Funktion Javascript-Funktion, die für die Verarbeitung verwendet wird
  • Handler integrierte Prozessor verwendet diesen Prozessor für die Verarbeitung
  • mq.Chain Sie Arrays in einer Kette, was der Rückgabe einer neuen mq.Chain (hdlr) entspricht, siehe Chain
  • Routing-Objekt, das der Rückgabe eines neuen mq.Routing (hdlr) entspricht, siehe Routing

Die Syntax der Nachrichtenverarbeitungsfunktion lautet wie folgt:

1
function func(v) {}

Der Parameter v ist die Nachricht, die verarbeitet wird. Es gibt vier Arten zulässiger Ergebnisse:

  • Funktion Javascript-Funktion, diese Funktion wird für die nächste Stufe der Verarbeitung verwendet
  • Handler integrierte Prozessor verwendet diesen Prozessor für die nächste Verarbeitungsstufe
  • mq.Chain Arrays in einer Kette, die der neuen mq.Chain (v) entsprechen, siehe Chain
  • Routing-Objekt, das dem neuen mq.Routing (v) entspricht, siehe Routing

Keine Rückgabe oder andere Rückgabeergebnisse beenden die Nachrichtenverarbeitung.


Chain

Erstellen Sie ein Kettenverarbeitungsobjekt für den Nachrichtenhandler, 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 Prozessorobjekt erstellen, wird das sekundäre Verarbeitungsobjekt ohne Verarbeitung direkt zurückgegeben

1
static Handler mq.nullHandler();

Gibt das Ergebnis zurück:

  • Handler , gibt einen leeren Handler zurück

invoke

Verarbeiten Sie eine Nachricht oder ein Objekt mit dem angegebenen Handler

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

Parameter aufrufen:

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

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