Module basismodule

module mq

berichtenwachtrijmodule

voorwerp

Message

Maak een berichtobject, zieMessage

1
Message mq.Message;

HttpHandler

Creërenhttpprotocolhandlerobject, zieHttpHandler

1
HttpHandler mq.HttpHandler;

Handler

Maak een berichtprocessorobject, geef de waarde door aan de ingebouwde processor en retourneer deze rechtstreeks

1
Handler mq.Handler;

Resultaten retourneren:

  • Retourneert de processor die de verwerkingsfunctie inkapselt

hdlr accepteert ingebouwde berichtprocessors, verwerkingsfuncties, gekoppelde verwerkingsarrays en routeringsobjecten:

  • Functie javascript-functie, deze functie wordt gebruikt voor de verwerking
  • HandlerIngebouwde processor, deze processor wordt gebruikt voor de verwerking
  • Het verwerken van arrays in een keten komt overeen met het retourneren van nieuwemq.Chain(hdlr), zieChain
  • Routeringsobject, gelijk aan het retourneren van nieuwmq.Routing(hdlr), zieRouting

De syntaxis van de berichtverwerkingsfunctie is als volgt:

1
function func(v) {}

Parameter v is het bericht dat wordt verwerkt en er zijn vier typen retourresultaten toegestaan:

  • Functie javascript-functie, deze functie wordt gebruikt voor de volgende verwerkingsfase
  • HandlerIngebouwde processor, deze processor wordt gebruikt voor de volgende verwerkingsfase
  • Ketenverwerking van arrays, gelijk aan nieuwmq.Chain(v), zieChain
  • Routeringsobject, gelijk aan nieuwmq.Routing(v), zieRouting

Geen enkele retourzending of ander retourresultaat beëindigt de berichtverwerking.


Chain

Maak een verwerkingsobject voor de berichthandlerketen, zieChain

1
Chain mq.Chain;

Routing

Maak een routeringsobject voor de berichtenhandler, zieRouting

1
Routing mq.Routing;

statische functie

nullHandler

Maak een leeg processorobject en het secundaire verwerkingsobject wordt direct zonder enige verwerking geretourneerd.

1
static Handler mq.nullHandler();

Resultaten retourneren:

  • Handler, retourneert een lege handlerfunctie

invoke

Verwerk een bericht of object met behulp van de gegeven handler

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

Oproepparameters:

  • hdlr:Handler, specificeert de te gebruiken processor
  • v:object, geef het bericht of object op dat moet worden verwerkt

In tegenstelling tot de aanroepmethode van de processor, loopt deze methode door de retourhandler van elke processor totdat de processor nul retourneert.