Objet objet intégré

Message d'objet

Objet de message de base

L'objet Message est compatible avec chaque module de mq et peut être utilisé pour créer un système de traitement de messages personnalisé. La méthode de création:

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

Héritage

Constructeur

Message

Constructeur d'objet de message

1
new Message();

constant

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, qui représente un type binaire

1
const Message.BINARY = 2;

Attributs 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, interrogez les données du message

1
readonly Value Message.data;

body

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

1
SeekableStream Message.body;

length

Long, la longueur de la partie données du message

1
readonly Long Message.length;

stream

Stream , l'objet de 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 des messages

1
String Message.lastError;

Fonction membre

read

Lire les données de la taille spécifiée dans le flux, cette méthode est un alias de la méthode correspondante du corps

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

Paramètres d'appel:

  • bytes : Entier, spécifiez la quantité de données à lire, la valeur par défaut est de lire les blocs de données de taille aléatoire, la taille des données lues dépend de l'appareil

Résultat de retour:

  • Buffer , retourne les données lues dans le flux, s'il n'y a pas de données à lire, ou si la connexion est interrompue, elle retourne null

readAll

Lire toutes les données restantes du flux, cette méthode est un alias de la méthode correspondante du corps

1
Buffer Message.readAll() async;

Résultat de retour:

  • Buffer , retourne les données lues dans le flux, s'il n'y a pas de données à lire, ou si la connexion est interrompue, elle retourne null

write

Écrivez les données données, cette méthode est l'alias de la méthode correspondante du corps

1
Message.write(Buffer data) async;

Paramètres d'appel:

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

json

Ecrire les données données dans l'encodage JSON

1
Value Message.json(Value data);

Paramètres d'appel:

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

Résultat de retour:

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

Analyser les données du message en encodage JSON

1
Value Message.json();

Résultat de retour:

  • Value , renvoie le résultat analysé

end

Définissez la fin du traitement des messages en cours et le processeur de Chain ne poursuivra plus les transactions suivantes

1
Message.end();

isEnded

Demander si le message actuel est terminé

1
Boolean Message.isEnded();

Résultat de retour:

  • Boolean , renvoie true à la fin

clear

Effacer le contenu du message

1
Message.clear();

sendTo

Envoyer 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 les messages formatés

readFrom

Lire le message formaté à partir de l'objet de flux de cache donné et analyser l'objet de remplissage

1
Message.readFrom(Stream stm) async;

Paramètres d'appel:

  • stm : Stream , spécifie l'objet de flux pour la lecture des messages formatés

toString

Renvoie la représentation sous forme de chaîne de l'objet, renvoie généralement "[Native Object]", l'objet peut être réimplémenté selon ses propres caractéristiques

1
String Message.toString();

Résultat de retour:

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

toJSON

Renvoie la représentation au format JSON de l'objet, renvoie généralement une collection d'attributs lisibles définis par l'objet

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

Paramètres d'appel:

  • key : chaîne, inutilisée

Résultat de retour:

  • Value , renvoie une valeur contenant JSON sérialisable