Módulo mq
Módulo de cola de mensajes
Objeto
Message
Cree un objeto de mensaje, consulte Message
1Message mq.Message;
HttpHandler
Cree un objeto de controlador de protocolo http , consulte HttpHandler
1HttpHandler mq.HttpHandler;
Handler
Cree un objeto de controlador de mensajes, pase el valor que el controlador incorporado devuelve directamente
1Handler mq.Handler;
Devolver resultado:
- Devuelve el procesador que encapsula la función de procesamiento.
hdlr acepta controladores de mensajes integrados, funciones de procesamiento, matrices de procesamiento en cadena y objetos de enrutamiento:
- Función función javascript, utilizará esta función para procesar
- Handler procesador integrado, utilizará este procesador para el procesamiento
- La matriz de procesamiento en cadena es equivalente a devolver un nuevo mq.Chain (hdlr), consulte Chain
- Objeto de enrutamiento, equivalente a devolver un nuevo mq.Routing (hdlr), consulte Routing
La sintaxis de la función de procesamiento de mensajes es la siguiente:
1function func(v) {}
El parámetro v es el mensaje que se está procesando y el resultado de la devolución permite cuatro tipos:
- Función función javascript, esta función se utilizará para la siguiente etapa de procesamiento
- Handler procesador incorporado, este procesador se usa para la siguiente etapa de procesamiento
- Matriz de procesamiento de cadena, equivalente a la nueva mq.Chain (v), consulte Chain
- Objeto de enrutamiento, equivalente al nuevo mq.Routing (v), consulte Routing
Ninguna devolución u otros resultados de devolución finalizarán el procesamiento del mensaje.
Chain
Cree un objeto de procesamiento de cadena de procesador de mensajes, consulte Chain
1Chain mq.Chain;
Routing
Cree un objeto de enrutamiento del procesador de mensajes, consulte Routing
1Routing mq.Routing;
Función estática
nullHandler
Cree un objeto de controlador vacío, el controlador secundario regresará directamente sin ningún procesamiento
1static Handler mq.nullHandler();
Devolver resultado:
- Handler , devuelve una función de controlador vacía
invoke
Utilizar un procesador determinado para procesar un mensaje u objeto
1
2static mq.invoke(Handler hdlr,
object v) async;
Parámetros de llamada:
- hdlr : Handler , especifique el procesador utilizado
- v : object , especifique el mensaje u objeto a procesar
A diferencia del método de invocación del procesador, este método llamará al procesador de retorno de cada procesador en un bucle hasta que el procesador devuelva un valor nulo.