Mensaje de objeto

Objeto de mensaje básico

El objeto Mensaje es compatible con todos los módulos de mq y puede usarse para construir un sistema de procesamiento de mensajes personalizado. El método de creación:

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

Herencia

Constructor

Message

Constructor de objetos de mensaje

1
new Message();

constante

TEXT

Especifique el tipo de mensaje 1, que representa un tipo de texto

1
const Message.TEXT = 1;

BINARY

Especifique el tipo de mensaje 2, que representa un tipo binario

1
const Message.BINARY = 2;

Atributos de miembros

value

String, el contenido básico del mensaje

1
String Message.value;

params

NArray, los parámetros básicos del mensaje

1
readonly NArray Message.params;

type

Entero, tipo de mensaje

1
Integer Message.type;

data

Valor, consulta los datos del mensaje

1
readonly Value Message.data;

body

SeekableStream , un objeto de flujo que contiene la parte de datos del mensaje

1
SeekableStream Message.body;

length

Long, la longitud de la parte de datos del mensaje

1
readonly Long Message.length;

stream

Stream , el objeto de flujo al consultar el mensaje readFrom

1
readonly Stream Message.stream;

lastError

Cadena, consulta y configuración del último error de procesamiento de mensajes

1
String Message.lastError;

Función miembro

read

Leer datos del tamaño especificado de la secuencia, este método es un alias del método correspondiente de cuerpo

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

Parámetros de llamada:

• bytes : entero, especifique la cantidad de datos que se leerán, el valor predeterminado es leer bloques de datos de tamaño aleatorio, el tamaño de los datos leídos depende del dispositivo

Devolver resultado:

• Buffer , devuelve los datos leídos de la transmisión, si no hay datos para leer o la conexión se interrumpe, devuelve nulo

readAll

Leer todos los datos restantes de la secuencia, este método es un alias del método correspondiente de body

1
Buffer Message.readAll() async;

Devolver resultado:

• Buffer , devuelve los datos leídos de la transmisión, si no hay datos para leer o la conexión se interrumpe, devuelve nulo

write

Escriba los datos dados, este método es el alias del método correspondiente de cuerpo

1
Message.write(Buffer data) async;

Parámetros de llamada:

• data : Buffer , dados los datos a escribir

json

Escribe los datos dados en codificación JSON

1
Value Message.json(Value data);

Parámetros de llamada:

• data : valor, dados los datos a escribir

Devolver resultado:

• Value , este método no devolverá datos

Analizar los datos del mensaje en codificación JSON

1
Value Message.json();

Devolver resultado:

• Value , devuelve el resultado analizado

end

Configure el procesamiento de mensajes actual para que finalice, y el procesador de Chain ya no continuará las transacciones posteriores

1
Message.end();

isEnded

Consultar si el mensaje actual ha terminado

1
Boolean Message.isEnded();

Devolver resultado:

• Boolean , devuelve verdadero al final

clear

Borrar el contenido del mensaje

1
Message.clear();

sendTo

Envía un mensaje formateado al objeto de transmisión dado

1
Message.sendTo(Stream stm) async;

Parámetros de llamada:

• stm : Stream , especifica el objeto de flujo que recibe mensajes formateados

readFrom

Leer el mensaje formateado del objeto de flujo de caché dado y analizar el objeto de relleno

1
Message.readFrom(Stream stm) async;

Parámetros de llamada:

• stm : Stream , especifica el objeto de flujo para leer mensajes formateados

toString

Devuelve la representación de cadena del objeto, generalmente devuelve "[Objeto nativo]", el objeto se puede volver a implementar de acuerdo con sus propias características

1
String Message.toString();

Devolver resultado:

• String , devuelve la representación de cadena del objeto.

toJSON

Devuelve la representación en formato JSON del objeto, generalmente devuelve una colección de atributos legibles definidos por el objeto

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

Parámetros de llamada:

• key : Cadena, no utilizada

Devolver resultado:

• Value , devuelve un valor que contiene JSON serializable