модуль мк
модуль очереди сообщений
объект
Message
Создайте объект сообщения, см.Message
1Message mq.Message;
HttpHandler
Создаватьhttpобъект обработчика протокола, см.HttpHandler
1HttpHandler mq.HttpHandler;
Handler
Создайте объект процессора сообщений, передайте значение встроенному процессору и верните его напрямую.
1Handler mq.Handler;
Результаты возврата:
- Возвращает процессор, инкапсулирующий функцию обработки.
hdlr принимает встроенные процессоры сообщений, функции обработки, массивы цепочки обработки и объекты маршрутизации:
- Функция Функция javascript, эта функция будет использоваться для обработки
- HandlerВстроенный процессор, этот процессор будет использоваться для обработки
- Обработка массивов в цепочке эквивалентна возврату новыхmq.Chain(hdlr), см.Chain
- Объект маршрутизации, эквивалентный возврату новогоmq.Routing(hdlr), см.Routing
Синтаксис функции обработки сообщений следующий:
1function func(v) {}
Параметр v — это обрабатываемое сообщение. Допускаются четыре типа возвращаемых результатов:
- Функция javascript функция, эта функция будет использоваться на следующем этапе обработки
- HandlerВстроенный процессор, этот процессор будет использоваться на следующем этапе обработки.
- Цепная обработка массивов, эквивалентная новымmq.Chain(в), см.Chain
- Объект маршрутизации, эквивалентный новомуmq.Routing(в), см.Routing
Отсутствие возврата или другого возвращаемого результата приведет к завершению обработки сообщения.
Chain
Создайте объект обработки цепочки обработчиков сообщений, см.Chain
1Chain mq.Chain;
Routing
Создайте объект маршрутизации обработчика сообщений, см.Routing
1Routing mq.Routing;
статическая функция
nullHandler
Создайте пустой объект процессора, и объект вторичной обработки будет возвращен напрямую без какой-либо обработки.
1static Handler mq.nullHandler();
Результаты возврата:
- Handler, возвращает пустую функцию-обработчик
invoke
Обработать сообщение или объект, используя данный обработчик
1
2static mq.invoke(Handler hdlr,
object v) async;
Параметры звонка:
- hdlr:Handler, указывает процессор, который будет использоваться
- v:object, укажите сообщение или объект для обработки
В отличие от метода вызова процессора, этот метод будет проходить через обработчик возврата каждого процессора, пока процессор не вернет ноль.