Módulo mq

Módulo de cola de mensaxes

Obxecto

Message

Crea un obxecto de mensaxe, ver Message

1
Message mq.Message;

---

HttpHandler

Crear http Obxecto manipulador de protocolo, ver HttpHandler

1
HttpHandler mq.HttpHandler;

---

Handler

Crea un obxecto de controlador de mensaxes, pasa o valor que devolve directamente o controlador incorporado

1
Handler 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:

1
function 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

1
Chain mq.Chain;

---

Routing

Crea un obxecto de encamiñamento do controlador de mensaxes, ver Routing

1
Routing mq.Routing;

Función estática

nullHandler

Crea un obxecto de controlador baleiro e o controlador secundario volverá directamente sen ningún procesamento

1
static Handler mq.nullHandler();

Resultado de volta:

• Handler, Devolve o controlador baleiro

---

invoke

Use un procesador determinado para procesar unha mensaxe ou obxecto

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

Parámetros de chamada:

• hdlr: Handler, O procesador especificado
• v: object, Especifique a mensaxe ou o obxecto a procesar

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.