Módulo mq

Módulo de cola de mensajes

Objeto

Message

Cree un objeto de mensaje, consulte Message

1
Message mq.Message;

---

HttpHandler

Crear http Objeto de controlador de protocolo, consulte HttpHandler

1
HttpHandler mq.HttpHandler;

---

Handler

Cree un objeto de controlador de mensajes, pase el valor que el controlador incorporado devuelve directamente

1
Handler 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 incorporado, utilizará este procesador para procesar
• Matriz de procesamiento en cadena, equivalente a devolver nueva mq.Chain(hdlr), ver Chain
• Objeto de ruta, equivalente a devolver nuevo mq.Routing(hdlr), ver Routing

La sintaxis de la función de procesamiento de mensajes es la siguiente:

1
function func(v) {}

El parámetro v es el mensaje que se está procesando y el resultado devuelto 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 utilizará para la siguiente etapa de procesamiento
• Matriz de procesamiento de cadena, equivalente a nueva mq.Chain(v), ver Chain
• Objeto de ruta, equivalente a nuevo mq.Routing(v), ver 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

1
Chain mq.Chain;

---

Routing

Cree un objeto de enrutamiento de controlador de mensajes, consulte Routing

1
Routing mq.Routing;

Función estática

nullHandler

Cree un objeto de controlador vacío y el controlador secundario regresará directamente sin ningún procesamiento

1
static Handler mq.nullHandler();

Devolver resultado:

• Handler, Devolver manipulador vacío

---

invoke

Utilizar un procesador determinado para procesar un mensaje u objeto

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

Parámetros de llamada:

• hdlr: Handler, El procesador especificado
• 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.