Module basic module

Module mq

Message queue module

Object

Message

Create a message object, see Message

1
Message mq.Message;

HttpHandler

Create an http protocol handler object, see HttpHandler

1
HttpHandler mq.HttpHandler;

Handler

Create a message handler object, pass the value built-in handler directly returns

1
Handler mq.Handler;

Return result:

  • Returns the processor that encapsulates the processing function

hdlr accepts built-in message handlers, processing functions, chain processing arrays, and routing objects:

  • Function javascript function, will use this function for processing
  • Handler built-in processor, will use this processor for processing
  • Chain processing array, equivalent to returning new mq.Chain (hdlr), see Chain
  • Routing object, equivalent to returning new mq.Routing (hdlr), see Routing

The message processing function syntax is as follows:

1
function func(v) {}

The parameter v is the message being processed, and the return result allows four types:

  • Function javascript function, this function will be used for the next stage of processing
  • Handler built-in processor, this processor will be used for the next stage of processing
  • Chain processing array, equivalent to new mq.Chain (v), see Chain
  • Routing object, equivalent to new mq.Routing (v), see Routing

No return or other return results will end the message processing.


Chain

Create a message processor chain processing object, see Chain

1
Chain mq.Chain;

Routing

Create a message processor routing object, see Routing

1
Routing mq.Routing;

Static function

nullHandler

Create an empty handler object, and the secondary handler will return directly without any processing

1
static Handler mq.nullHandler();

Return result:

  • Handler , returns an empty handler function

invoke

Use a given processor to process a message or object

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

Call parameters:

  • hdlr : Handler , specify the processor used
  • v : object , specify the message or object to be processed

Different from the invoke method of the processor, this method will call the return processor of each processor in a loop until the processor returns null.