module mq
berichtenwachtrijmodule
voorwerp
Message
Maak een berichtobject, zieMessage
1Message mq.Message;
HttpHandler
Creërenhttpprotocolhandlerobject, zieHttpHandler
1HttpHandler mq.HttpHandler;
Handler
Maak een berichtprocessorobject, geef de waarde door aan de ingebouwde processor en retourneer deze rechtstreeks
1Handler 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:
1function 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
1Chain mq.Chain;
Routing
Maak een routeringsobject voor de berichtenhandler, zieRouting
1Routing mq.Routing;
statische functie
nullHandler
Maak een leeg processorobject en het secundaire verwerkingsobject wordt direct zonder enige verwerking geretourneerd.
1static Handler mq.nullHandler();
Resultaten retourneren:
- Handler, retourneert een lege handlerfunctie
invoke
Verwerk een bericht of object met behulp van de gegeven handler
1
2static 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.