ObjectMessage

Obxecto de mensaxe básico

Os obxectos de mensaxe son compatiblesmqCada módulo pódese usar para construír un sistema de procesamento de mensaxes personalizado. O método de creación é:

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

relación de herdanza

Construtor

Message

Construtor de obxectos de mensaxe

1
new Message();

constante

TEXT

Especifique o tipo de mensaxe 1, que representa un tipo de texto

1
const Message.TEXT = 1;

---

BINARY

Especifique o tipo de mensaxe 2, que representa un tipo binario

1
const Message.BINARY = 2;

propiedades dos membros

value

String, o contido básico da mensaxe

1
String Message.value;

---

params

NArray, os parámetros básicos da mensaxe

1
readonly NArray Message.params;

---

type

Número enteiro, tipo de mensaxe

1
Integer Message.type;

---

data

Valor, consulta os datos da mensaxe. Este atributo devolverá datos diferentes segundo o tipo de contido. Cando sexa texto, devolverase o texto.jsonvolver candojson, se non, devolve binario

1
readonly Value Message.data;

---

body

SeekableStream, un obxecto de fluxo que contén a parte de datos da mensaxe

1
SeekableStream Message.body;

---

length

Long, a lonxitude da parte de datos da mensaxe

1
readonly Long Message.length;

---

stream

Stream, o obxecto de fluxo cando se consulta a mensaxe readFrom

1
readonly Stream Message.stream;

---

lastError

Cadena, consulta e establece o último erro de procesamento da mensaxe

1
String Message.lastError;

función de membro

read

Le datos do tamaño especificado do fluxo. Este método é un alias do método correspondente do corpo.

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

Parámetros de chamada:

• bytes: Número enteiro, especifica a cantidade de datos que se van ler. O valor predeterminado é ler bloques de datos de tamaño aleatorio. O tamaño dos datos lidos depende do dispositivo.

Resultados de devolución:

• Buffer, devolve os datos lidos do fluxo. Se non hai datos para ler ou se interrompe a conexión, devólvese nulo.

---

readAll

Le todos os datos restantes do fluxo. Este método é un alias do método correspondente do corpo.

1
Buffer Message.readAll() async;

Resultados de devolución:

• Buffer, devolve os datos lidos do fluxo. Se non hai datos para ler ou se interrompe a conexión, devólvese nulo.

---

write

Escribe os datos dados. Este método é un alias do método correspondente no corpo.

1
Message.write(Buffer data) async;

Parámetros de chamada:

• data:Buffer, dados os datos a escribir

---

json

Escribe os datos proporcionados en codificación JSON

1
Value Message.json(Value data);

Parámetros de chamada:

• data: Valor, dados os datos a escribir

Resultados de devolución:

• Value, este método non devolve datos

---

Analiza os datos da mensaxe como codificación JSON

1
Value Message.json();

Resultados de devolución:

• Value, devolve o resultado analizado

---

pack

pormsgpackA codificación escribe os datos dados

1
Value Message.pack(Value data);

Parámetros de chamada:

• data: Valor, dados os datos a escribir

Resultados de devolución:

• Value, este método non devolve datos

---

pormsgpackCodificación e análise dos datos da mensaxe

1
Value Message.pack();

Resultados de devolución:

• Value, devolve o resultado analizado

---

end

Establece o final do procesamento da mensaxe actual,ChainO procesador non continúa coas transaccións posteriores

1
Message.end();

---

isEnded

Consulta se a mensaxe actual rematou

1
Boolean Message.isEnded();

Resultados de devolución:

• Boolean, devolve verdadeiro cando remate

---

clear

Borrar o contido da mensaxe

1
Message.clear();

---

sendTo

Envía unha mensaxe con formato ao obxecto de fluxo indicado

1
Message.sendTo(Stream stm) async;

Parámetros de chamada:

• stm:Stream, especifica o obxecto de fluxo que recibe a mensaxe con formato

---

readFrom

Le a mensaxe con formato do obxecto de fluxo de caché indicado e analiza o obxecto poboado

1
Message.readFrom(Stream stm) async;

Parámetros de chamada:

• stm:Stream, especifica o obxecto de fluxo para ler mensaxes con formato

---

toString

Devolve a representación en cadea do obxecto. Polo xeral, devólvese "[Obxecto nativo]". O obxecto pódese volver implementar segundo as súas propias características.

1
String Message.toString();

Resultados de devolución:

• String, devolve a representación en cadea do obxecto

---

toJSON

Devolve unha representación en formato JSON do obxecto, devolvendo xeralmente unha colección de propiedades lexibles definidas polo obxecto.

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

Parámetros de chamada:

• key: Cadena, non usada

Resultados de devolución:

• Value, devolve un valor que contén JSON serializable