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
2
var mq = require("mq");
var m = new mq.Message();

Eredità

Costruttore

Message

Costruttore dell'oggetto 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;

Attributi dei membri

value

String, il contenuto di base del messaggio

1
String Message.value;

params

NArray, i parametri di base del messaggio

1
readonly NArray Message.params;

type

Intero, tipo di messaggio

1
Integer Message.type;

data

Value, interroga i dati del messaggio

1
readonly Value Message.data;

body

SeekableStream , l'oggetto stream contenente la parte di 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 stream durante la query del 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

Leggi i dati della dimensione specificata dal flusso, questo metodo è un alias del metodo di body corrispondente

1
Buffer 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

1
Buffer 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

1
Message.write(Buffer data) async;

Parametri di chiamata:

• data : Buffer , dati i dati da scrivere

json

Scrivi i dati forniti nella codifica JSON

1
Value 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

1
Value 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

1
Message.end();

isEnded

Verifica se il messaggio corrente è terminato

1
Boolean Message.isEnded();

Risultato di ritorno:

• Boolean , restituisce vero alla fine

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 stream che riceve i messaggi formattati

readFrom

Leggere il messaggio formattato dall'oggetto flusso di cache specificato e analizzare l'oggetto di riempimento

1
Message.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

1
String 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

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

Parametri di chiamata:

• key : stringa, non utilizzata

Risultato di ritorno:

• Value , restituisce un valore contenente JSON serializzabile