OggettoMessaggio

Oggetto messaggio di base

Gli oggetti messaggio sono compatibili conmqOgni modulo può essere utilizzato per costruire un sistema di elaborazione dei messaggi personalizzato. Il metodo di creazione è:

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

rapporto ereditario

Costruttore

Message

Costruttore di oggetti messaggio

1
new Message();

costante

TEXT

Specificare il tipo di messaggio 1, che rappresenta un tipo di testo

1
const Message.TEXT = 1;

---

BINARY

Specificare il tipo di messaggio 2, che rappresenta un tipo binario

1
const Message.BINARY = 2;

proprietà dei membri

value

Stringa, il contenuto di base del messaggio

1
String Message.value;

---

params

NArray, i parametri di base del messaggio

1
readonly NArray Message.params;

---

type

Numero intero, tipo di messaggio

1
Integer Message.type;

---

data

Valore, interroga i dati del messaggio. Questo attributo restituirà dati diversi a seconda del tipo di contenuto. Quando è testo, verrà restituito il testo.jsontornare quandojson, altrimenti restituisce binario

1
readonly Value Message.data;

---

body

SeekableStream, un oggetto flusso contenente la parte dati del messaggio

1
SeekableStream Message.body;

---

length

Long, la lunghezza della parte dei dati del messaggio

1
readonly Long Message.length;

---

stream

Stream, l'oggetto flusso quando si interroga il messaggio readFrom

1
readonly Stream Message.stream;

---

lastError

Stringa, interroga e imposta l'ultimo errore di elaborazione del messaggio

1
String Message.lastError;

funzione membro

read

Legge i dati della dimensione specificata dal flusso. Questo metodo è un alias del metodo corrispondente del corpo.

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

Parametri di chiamata:

• bytes: Numero intero, specifica la quantità di dati da leggere. L'impostazione predefinita prevede la lettura di blocchi di dati di dimensione casuale. La dimensione dei dati letti dipende dal dispositivo.

Risultati restituiti:

• Buffer, restituisce i dati letti dallo stream. Se non ci sono dati da leggere o la connessione viene interrotta, viene restituito null.

---

readAll

Legge tutti i dati rimanenti dallo stream. Questo metodo è un alias del metodo corrispondente del corpo.

1
Buffer Message.readAll() async;

Risultati restituiti:

• Buffer, restituisce i dati letti dallo stream. Se non ci sono dati da leggere o la connessione viene interrotta, viene restituito null.

---

write

Scrivi i dati forniti. Questo metodo è un alias del metodo corrispondente nel corpo.

1
Message.write(Buffer data) async;

Parametri di chiamata:

• data:Buffer, dati i dati da scrivere

---

json

Scrive i dati specificati nella codifica JSON

1
Value Message.json(Value data);

Parametri di chiamata:

• data: Valore, dati i dati da scrivere

Risultati restituiti:

• Value, questo metodo non restituisce dati

---

Analizza i dati nel messaggio come codifica JSON

1
Value Message.json();

Risultati restituiti:

• Value, restituisce il risultato analizzato

---

pack

dimsgpackLa codifica scrive i dati forniti

1
Value Message.pack(Value data);

Parametri di chiamata:

• data: Valore, dati i dati da scrivere

Risultati restituiti:

• Value, questo metodo non restituisce dati

---

dimsgpackCodifica e analisi dei dati nel messaggio

1
Value Message.pack();

Risultati restituiti:

• Value, restituisce il risultato analizzato

---

end

Imposta la fine dell'elaborazione del messaggio corrente,ChainIl processore non continua con le transazioni successive

1
Message.end();

---

isEnded

Interroga se il messaggio corrente è terminato

1
Boolean Message.isEnded();

Risultati restituiti:

• Boolean, restituisce vero al termine

---

clear

Cancella il contenuto del messaggio

1
Message.clear();

---

sendTo

Invia un messaggio formattato all'oggetto flusso specificato

1
Message.sendTo(Stream stm) async;

Parametri di chiamata:

• stm:Stream, specifica l'oggetto flusso che riceve il messaggio formattato

---

readFrom

Legge il messaggio formattato dall'oggetto flusso cache specificato e analizza l'oggetto popolato

1
Message.readFrom(Stream stm) async;

Parametri di chiamata:

• stm:Stream, specifica l'oggetto flusso per la lettura dei messaggi formattati

---

toString

Restituisce la rappresentazione in formato stringa dell'oggetto. Generalmente viene restituito "[Oggetto nativo]". L'oggetto può essere reimplementato in base alle proprie caratteristiche.

1
String Message.toString();

Risultati restituiti:

• String, restituisce la rappresentazione di stringa dell'oggetto

---

toJSON

Restituisce una rappresentazione in formato JSON dell'oggetto, generalmente restituendo una raccolta di proprietà leggibili definite dall'oggetto.

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

Parametri di chiamata:

• key: Stringa, non utilizzata

Risultati restituiti:

• Value, restituisce un valore contenente JSON serializzabile