Объект встроенный объект

Сообщение объекта

Основной объект сообщения

Объект Message совместим со всеми модулями mq и может использоваться для создания собственной системы обработки сообщений.

1 2
var mq = require("mq"); var m = new mq.Message();

наследование

Конструктор

Message

Конструктор объекта сообщения

1
new Message();

постоянная

TEXT

Укажите тип сообщения 1, представляющий тип текста

1
const Message.TEXT = 1;

BINARY

Укажите тип сообщения 2, представляющий двоичный тип

1
const Message.BINARY = 2;

Атрибут члена

value

Строка, основное содержание сообщения

1
String Message.value;

params

NArray, основные параметры сообщения

1
readonly NArray Message.params;

type

Целое число, тип сообщения

1
Integer Message.type;

data

Значение, запросить данные сообщения

1
readonly Value Message.data;

body

SeekableStream , объект потока, содержащий часть данных сообщения

1
SeekableStream Message.body;

length

Long, длина части данных сообщения

1
readonly Long Message.length;

stream

Stream , объект потока при запросе сообщения readFrom

1
readonly Stream Message.stream;

lastError

Строка, последняя ошибка запроса и настройки обработки сообщения

1
String Message.lastError;

Функция-член

read

Чтение указанного размера данных из потока, этот метод является псевдонимом для соответствующего метода тела

1
Buffer Message.read(Integer bytes = -1) async;

Параметры вызова:

  • bytes : Integer, задает объем данных, которые нужно прочитать, по умолчанию - чтение блоков данных произвольного размера, размер прочитанных данных зависит от устройства.

Вернуть результат:

  • Buffer , возвращает данные, прочитанные из потока, или ноль, если данные не читаются или соединение прервано

readAll

Прочитайте все оставшиеся данные из потока, этот метод является псевдонимом для соответствующего метода тела

1
Buffer Message.readAll() async;

Вернуть результат:

  • Buffer , возвращает данные, прочитанные из потока, или ноль, если данные не читаются или соединение прервано

write

Записать данные данные, этот метод является псевдонимом для соответствующего метода тела

1
Message.write(Buffer data) async;

Параметры вызова:

  • data : Buffer , учитывая данные для записи

json

Запишите данные в кодировке JSON

1
Value Message.json(Value data);

Параметры вызова:

  • data : значение, учитывая данные для записи

Вернуть результат:

  • Value , этот метод не возвращает данные

Разобрать данные в сообщении в кодировке JSON

1
Value Message.json();

Вернуть результат:

  • Value , вернуть проанализированный результат

end

Установите текущую обработку сообщения, чтобы закончить, Chain процессор не будет продолжать последующую транзакцию

1
Message.end();

isEnded

Запрос, закончилось ли текущее сообщение

1
Boolean Message.isEnded();

Вернуть результат:

  • Boolean , вернуть true в конце

clear

Очистить содержание сообщения

1
Message.clear();

sendTo

Отправить отформатированное сообщение данному объекту потока

1
Message.sendTo(Stream stm) async;

Параметры вызова:

  • stm : Stream , указать объект потока для получения отформатированных сообщений

readFrom

Прочитать отформатированное сообщение из данного объекта потока кэша и проанализировать объект заполнения

1
Message.readFrom(Stream stm) async;

Параметры вызова:

  • stm : Stream , указать объект потока для чтения отформатированных сообщений

toString

Возвращает строковое представление объекта, обычно возвращает «[Native Object]», объект может быть переопределён согласно его собственным характеристикам

1
String Message.toString();

Вернуть результат:

  • String , возвращает строковое представление объекта

toJSON

Возвращает JSON-представление объекта, как правило, возвращает коллекцию читаемых атрибутов, определенных объектом

1
Value Message.toJSON(String key = "");

Параметры вызова:

  • key : строка, не используется

Вернуть результат:

  • Value , возвращает значение, содержащее сериализуемый JSON