Módulo mq
Módulo de cola de mensaxes
Obxecto
Message
Crea un obxecto de mensaxe, ver Message
1Message mq.Message;
HttpHandler
Crear http Obxecto manipulador de protocolo, ver HttpHandler
1HttpHandler mq.HttpHandler;
Handler
Crea un obxecto de controlador de mensaxes, pasa o valor que devolve directamente o controlador incorporado
1Handler mq.Handler;
Resultado de volta:
- Devolve o procesador que encapsula a función de procesamento
hdlr acepta controladores de mensaxes integrados, funcións de procesamento, matrices de procesamento de cadeas e obxectos de encamiñamento:
- Función javascript, empregará esta función para o procesamento
- Handler O procesador incorporado utilizará este procesador para o procesamento
- Matriz de procesamento de cadea, equivalente a volver novo mq.Chain(hdlr), ver Chain
- Obxecto de ruta, equivalente a devolver o novo mq.Routing(hdlr), ver Routing
A sintaxe da función de procesamento de mensaxes é a seguinte:
1function func(v) {}
O parámetro v é a mensaxe que se está procesando e o resultado de devolución permite catro tipos:
- Función función javascript, esta función utilizarase para a seguinte etapa do procesamento
- Handler Procesador incorporado, este procesador utilizarase para a seguinte etapa do procesamento
- Matriz de procesamento de cadea, equivalente a nova mq.Chain(v), ver Chain
- Obxecto de ruta, equivalente a novo mq.Routing(v), ver Routing
Sen devolución ou outros resultados de devolución finalizará o procesamento da mensaxe.
Chain
Crea un obxecto de procesamento de cadea de procesador de mensaxes, ver Chain
1Chain mq.Chain;
Routing
Crea un obxecto de encamiñamento do controlador de mensaxes, ver Routing
1Routing mq.Routing;
Función estática
nullHandler
Crea un obxecto de controlador baleiro e o controlador secundario volverá directamente sen ningún procesamento
1static Handler mq.nullHandler();
Resultado de volta:
- Handler, Devolve o controlador baleiro
invoke
Use un procesador determinado para procesar unha mensaxe ou obxecto
1
2static mq.invoke(Handler hdlr,
object v) async;
Parámetros de chamada:
A diferenza do método de invocación do procesador, este método chamará ao procesador de retorno de cada procesador nun bucle ata que o procesador devolva nulo.