Objeto objeto incorporado

Mensaje de objeto

Objeto de mensaje base

El objeto Mensaje es compatible con varios módulos de mq y puede usarse para construir un sistema de procesamiento de mensajes personalizado.

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

Herencia

Constructor

Message

Constructor de objeto de mensaje

1
new Message();

Constante

TEXT

Especifique el tipo de mensaje 1 para un tipo de texto

1
const Message.TEXT = 1;

BINARY

Especifique el tipo de mensaje 2 para un tipo binario

1
const Message.BINARY = 2;

Atributos del miembro

value

Cadena, 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 de datos del mensaje

1
readonly Value Message.data;

body

SeekableStream , un objeto SeekableStream que contiene la porción de datos del mensaje

1
SeekableStream Message.body;

length

Largo, la longitud de la parte de datos del mensaje

1
readonly Long Message.length;

stream

Stream , el objeto stream al consultar el mensaje readFrom

1
readonly Stream Message.stream;

lastError

Cadena, consulta y establece el último error en el procesamiento de mensajes

1
String Message.lastError;

Función miembro

read

Lee datos del tamaño especificado de la secuencia. Este método es un alias para el método correspondiente del cuerpo.

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

Parámetros de llamada:

  • bytes : Entero, especifica la cantidad de datos a leer. El valor predeterminado es leer bloques de datos de tamaño aleatorio. El tamaño de los datos leídos depende del dispositivo.

Devuelve el resultado:

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

readAll

Lea todos los datos restantes de la secuencia. Este método es un alias para el método correspondiente del cuerpo

1
Buffer Message.readAll() async;

Devuelve el resultado:

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

write

Escriba los datos dados, este método es un alias para el método correspondiente del 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

Devuelve el resultado:

  • Value , este método no devuelve datos

Analizar datos en mensajes como JSON

1
Value Message.json();

Devuelve el resultado:

  • Value , devuelve el resultado analizado

end

Establezca el final del procesamiento del mensaje actual, el procesador de la Chain no continuará las transacciones posteriores

1
Message.end();

isEnded

Consulta si finaliza el mensaje actual

1
Boolean Message.isEnded();

Devuelve el resultado:

  • Boolean , devuelve verdadero al final

clear

Borrar el contenido del mensaje

1
Message.clear();

sendTo

Enviar un mensaje formateado al objeto de flujo dado

1
Message.sendTo(Stream stm) async;

Parámetros de llamada:

  • stm : Stream , especificando el objeto de stream para recibir mensajes formateados

readFrom

Lee mensajes formateados del objeto de flujo de caché dado y analiza el objeto lleno

1
Message.readFrom(Stream stm) async;

Parámetros de llamada:

  • stm : Stream , especificando un objeto de flujo para leer mensajes formateados

toString

Devuelve una representación de cadena del objeto, generalmente "[Objeto nativo]". Los objetos se pueden volver a implementar de acuerdo con sus propias características

1
String Message.toString();

Devuelve el resultado:

  • String , devuelve una representación de cadena del objeto

toJSON

Devuelve una representación JSON del objeto, que generalmente devuelve una colección de propiedades legibles definidas por el objeto

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

Parámetros de llamada:

  • key : cadena, sin usar

Devuelve el resultado:

  • Value , devuelve un valor que contiene un JSON serializable