ObjetMessage

Objet de message de base

Les objets de message sont compatibles avecmqChaque module peut être utilisé pour construire un système de traitement de messages personnalisé. La méthode de création est la suivante :

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

relation d'héritage

Constructeur

Message

Constructeur d'objet de message

1
new Message();

constante

TEXT

Spécifiez le type de message 1, qui représente un type de texte

1
const Message.TEXT = 1;

---

BINARY

Spécifiez le type de message 2, représentant un type binaire

1
const Message.BINARY = 2;

propriétés des membres

value

String, le contenu de base du message

1
String Message.value;

---

params

NArray, les paramètres de base du message

1
readonly NArray Message.params;

---

type

Entier, type de message

1
Integer Message.type;

---

data

Valeur, interroge les données du message. Cet attribut renverra des données différentes en fonction du type de contenu. Lorsqu'il s'agit de texte, le texte sera renvoyé.jsonrevenir quandjson, sinon il renvoie du binaire

1
readonly Value Message.data;

---

body

SeekableStream, un objet flux contenant la partie données du message

1
SeekableStream Message.body;

---

length

Long : la longueur de la partie des données du message

1
readonly Long Message.length;

---

stream

Stream, l'objet flux lors de l'interrogation du message readFrom

1
readonly Stream Message.stream;

---

lastError

Chaîne, interroge et définit la dernière erreur de traitement du message

1
String Message.lastError;

fonction membre

read

Lit des données de taille spécifiée à partir du flux.Cette méthode est un alias de la méthode correspondante de body.

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

Paramètres d'appel :

• bytes : Nombre entier, spécifie la quantité de données à lire. La valeur par défaut est de lire des blocs de données de taille aléatoire. La taille des données lues dépend de l'appareil.

Résultats de retour :

• Buffer, renvoie les données lues à partir du flux. S'il n'y a aucune donnée à lire ou si la connexion est interrompue, null est renvoyé.

---

readAll

Lit toutes les données restantes du flux.Cette méthode est un alias de la méthode correspondante de body.

1
Buffer Message.readAll() async;

Résultats de retour :

• Buffer, renvoie les données lues à partir du flux. S'il n'y a aucune donnée à lire ou si la connexion est interrompue, null est renvoyé.

---

write

Écrivez les données données.Cette méthode est un alias de la méthode correspondante dans le corps.

1
Message.write(Buffer data) async;

Paramètres d'appel :

• data:Buffer, étant donné les données à écrire

---

json

Écrit les données données en codage JSON

1
Value Message.json(Value data);

Paramètres d'appel :

• data: Valeur, compte tenu des données à écrire

Résultats de retour :

• Value, cette méthode ne renvoie pas de données

---

Analyser les données du message sous forme d'encodage JSON

1
Value Message.json();

Résultats de retour :

• Value, renvoie le résultat analysé

---

pack

parmsgpackL'encodage écrit les données données

1
Value Message.pack(Value data);

Paramètres d'appel :

• data: Valeur, compte tenu des données à écrire

Résultats de retour :

• Value, cette méthode ne renvoie pas de données

---

parmsgpackEncodage et analyse des données dans le message

1
Value Message.pack();

Résultats de retour :

• Value, renvoie le résultat analysé

---

end

Définir la fin du traitement du message en cours,ChainLe processeur ne poursuit pas les transactions ultérieures

1
Message.end();

---

isEnded

Demander si le message en cours est terminé

1
Boolean Message.isEnded();

Résultats de retour :

• Boolean, renvoie vrai une fois terminé

---

clear

Contenu clair du message

1
Message.clear();

---

sendTo

Envoie un message formaté à l'objet de flux donné

1
Message.sendTo(Stream stm) async;

Paramètres d'appel :

• stm:Stream, spécifie l'objet de flux qui reçoit le message formaté

---

readFrom

Lit le message formaté à partir de l'objet de flux de cache donné et analyse l'objet renseigné

1
Message.readFrom(Stream stm) async;

Paramètres d'appel :

• stm:Stream, spécifie l'objet de flux pour lire les messages formatés

---

toString

Renvoie la représentation sous forme de chaîne de l'objet. Généralement, "[Native Object]" est renvoyé. L'objet peut être réimplémenté en fonction de ses propres caractéristiques.

1
String Message.toString();

Résultats de retour :

• String, renvoie la représentation sous forme de chaîne de l'objet

---

toJSON

Renvoie une représentation au format JSON de l'objet, renvoyant généralement une collection de propriétés lisibles définies par l'objet.

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

Paramètres d'appel :

• key: Chaîne, non utilisée

Résultats de retour :

• Value, renvoie une valeur contenant du JSON sérialisable