Messaggio oggetto
Oggetto messaggio di base
L'oggetto Message è compatibile con ogni modulo di mq e può essere utilizzato per costruire un sistema di elaborazione messaggi personalizzato. Il metodo di creazione:
1
2var mq = require("mq");
var m = new mq.Message();
Eredità
Costruttore
Message
Costruttore dell'oggetto messaggio
1new Message();
costante
TEXT
Specificare il tipo di messaggio 1, che rappresenta un tipo di testo
1const Message.TEXT = 1;
BINARY
Specificare il tipo di messaggio 2, che rappresenta un tipo binario
1const Message.BINARY = 2;
Attributi dei membri
value
String, il contenuto di base del messaggio
1String Message.value;
params
NArray, i parametri di base del messaggio
1readonly NArray Message.params;
type
Intero, tipo di messaggio
1Integer Message.type;
data
Value, interroga i dati del messaggio
1readonly Value Message.data;
body
SeekableStream , l'oggetto stream contenente la parte di dati del messaggio
1SeekableStream Message.body;
length
Long, la lunghezza della parte dei dati del messaggio
1readonly Long Message.length;
stream
Stream , l'oggetto stream durante la query del messaggio readFrom
1readonly Stream Message.stream;
lastError
Stringa, interroga e imposta l'ultimo errore di elaborazione del messaggio
1String Message.lastError;
Funzione membro
read
Leggi i dati della dimensione specificata dal flusso, questo metodo è un alias del metodo di body corrispondente
1Buffer Message.read(Integer bytes = -1) async;
Parametri di chiamata:
- bytes : numero intero, specificare la quantità di dati da leggere, l'impostazione predefinita è leggere blocchi di dati di dimensioni casuali, la dimensione dei dati letti dipende dal dispositivo
Risultato di ritorno:
- Buffer , restituisce i dati letti dallo stream, se non ci sono dati da leggere, o la connessione viene interrotta, restituisce null
readAll
Leggi tutti i dati rimanenti dal flusso, questo metodo è un alias del metodo di body corrispondente
1Buffer Message.readAll() async;
Risultato di ritorno:
- Buffer , restituisce i dati letti dallo stream, se non ci sono dati da leggere, o la connessione viene interrotta, restituisce null
write
Scrivi i dati forniti, questo metodo è l'alias del metodo di body corrispondente
1Message.write(Buffer data) async;
Parametri di chiamata:
- data : Buffer , dati i dati da scrivere
json
Scrivi i dati forniti nella codifica JSON
1Value Message.json(Value data);
Parametri di chiamata:
- data : valore, dati i dati da scrivere
Risultato di ritorno:
- Value , questo metodo non restituirà dati
Analizza i dati nel messaggio nella codifica JSON
1Value Message.json();
Risultato di ritorno:
- Value , restituisce il risultato analizzato
end
Impostare l'elaborazione del messaggio corrente per terminare e il processore Chain non continuerà le transazioni successive
1Message.end();
isEnded
Verifica se il messaggio corrente è terminato
1Boolean Message.isEnded();
Risultato di ritorno:
- Boolean , restituisce vero alla fine
clear
Cancella il contenuto del messaggio
1Message.clear();
sendTo
Invia un messaggio formattato all'oggetto flusso specificato
1Message.sendTo(Stream stm) async;
Parametri di chiamata:
- stm : Stream , specifica l'oggetto stream che riceve i messaggi formattati
readFrom
Leggere il messaggio formattato dall'oggetto flusso di cache specificato e analizzare l'oggetto di riempimento
1Message.readFrom(Stream stm) async;
Parametri di chiamata:
- stm : Stream , specifica l'oggetto stream per leggere i messaggi formattati
toString
Restituisce la rappresentazione in stringa dell'oggetto, generalmente restituisce "[Native Object]", l'oggetto può essere reimplementato secondo le proprie caratteristiche
1String Message.toString();
Risultato di ritorno:
- String , restituisce la rappresentazione di stringa dell'oggetto
toJSON
Restituisce la rappresentazione in formato JSON dell'oggetto, generalmente restituisce una raccolta di attributi leggibili definiti dall'oggetto
1Value Message.toJSON(String key = "");
Parametri di chiamata:
- key : stringa, non utilizzata
Risultato di ritorno:
- Value , restituisce un valore contenente JSON serializzabile