Objectbericht

Basisberichtobject

Berichtobjecten zijn compatibel metmqElke module kan worden gebruikt om een ​​aangepast berichtenverwerkingssysteem te bouwen. De aanmaakmethode is:

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

erfenis relatie

Constructeur

Message

Constructor van berichtobject

1
new Message();

constante

TEXT

Geef berichttype 1 op, dat een teksttype vertegenwoordigt

1
const Message.TEXT = 1;

---

BINARY

Geef berichttype 2 op, dat een binair type vertegenwoordigt

1
const Message.BINARY = 2;

eigenschappen van leden

value

String, de basisinhoud van het bericht

1
String Message.value;

---

params

NArray, de basisparameters van het bericht

1
readonly NArray Message.params;

---

type

Geheel getal, berichttype

1
Integer Message.type;

---

data

Waarde, zoek naar de gegevens van het bericht. Dit attribuut retourneert verschillende gegevens, afhankelijk van het inhoudstype. Als het tekst is, wordt de tekst geretourneerd.jsonwanneer terugjson, anders retourneert het binair

1
readonly Value Message.data;

---

body

SeekableStream, een stroomobject dat het gegevensgedeelte van het bericht bevat

1
SeekableStream Message.body;

---

length

Lang: de lengte van het berichtgegevensgedeelte

1
readonly Long Message.length;

---

stream

Stream, het streamobject bij het opvragen van het bericht readFrom

1
readonly Stream Message.stream;

---

lastError

Tekenreeks, query en stel de laatste fout van de berichtverwerking in

1
String Message.lastError;

lid functie

read

Gegevens van een opgegeven grootte uit de stream lezen. Deze methode is een alias van de overeenkomstige body-methode.

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

Oproepparameters:

• bytes: Geheel getal, specificeert de hoeveelheid gegevens die moeten worden gelezen. De standaardinstelling is het lezen van gegevensblokken van willekeurige grootte. De grootte van de gelezen gegevens is afhankelijk van het apparaat.

Resultaten retourneren:

• Buffer, retourneert de gegevens die uit de stream zijn gelezen. Als er geen gegevens zijn om te lezen of als de verbinding wordt onderbroken, wordt null geretourneerd.

---

readAll

Lees alle resterende gegevens uit de stream. Deze methode is een alias van de overeenkomstige methode van body.

1
Buffer Message.readAll() async;

Resultaten retourneren:

• Buffer, retourneert de gegevens die uit de stream zijn gelezen. Als er geen gegevens zijn om te lezen of als de verbinding wordt onderbroken, wordt null geretourneerd.

---

write

Schrijf de gegeven gegevens. Deze methode is een alias van de overeenkomstige methode in body.

1
Message.write(Buffer data) async;

Oproepparameters:

• data:Buffer, gegeven de te schrijven gegevens

---

json

Schrijft de gegeven gegevens in JSON-codering

1
Value Message.json(Value data);

Oproepparameters:

• data: Waarde, gegeven de te schrijven gegevens

Resultaten retourneren:

• Value, retourneert deze methode geen gegevens

---

Parseer de gegevens in het bericht als JSON-codering

1
Value Message.json();

Resultaten retourneren:

• Value, retourneert het geparseerde resultaat

---

pack

doormsgpackCodering schrijft de gegeven gegevens

1
Value Message.pack(Value data);

Oproepparameters:

• data: Waarde, gegeven de te schrijven gegevens

Resultaten retourneren:

• Value, retourneert deze methode geen gegevens

---

doormsgpackCoderen en parseren van de gegevens in het bericht

1
Value Message.pack();

Resultaten retourneren:

• Value, retourneert het geparseerde resultaat

---

end

Stel het einde van de huidige berichtverwerking in,ChainDe verwerker gaat niet verder met vervolgtransacties

1
Message.end();

---

isEnded

Vraag op of het huidige bericht is beëindigd

1
Boolean Message.isEnded();

Resultaten retourneren:

• Boolean, retourneert waar als u klaar bent

---

clear

Duidelijke berichtinhoud

1
Message.clear();

---

sendTo

Stuurt een opgemaakt bericht naar het opgegeven streamobject

1
Message.sendTo(Stream stm) async;

Oproepparameters:

• stm:Stream, specificeert het streamobject dat het opgemaakte bericht ontvangt

---

readFrom

Leest het opgemaakte bericht van het gegeven cachestreamobject en ontleedt het ingevulde object

1
Message.readFrom(Stream stm) async;

Oproepparameters:

• stm:Stream, specificeert het streamobject voor het lezen van opgemaakte berichten

---

toString

Retourneert de tekenreeksweergave van het object. Over het algemeen wordt '[Native Object]' geretourneerd. Het object kan opnieuw worden geïmplementeerd op basis van zijn eigen kenmerken.

1
String Message.toString();

Resultaten retourneren:

• String, retourneert de tekenreeksrepresentatie van het object

---

toJSON

Retourneert een weergave in JSON-indeling van het object, waarbij doorgaans een verzameling leesbare eigenschappen wordt geretourneerd die door het object zijn gedefinieerd.

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

Oproepparameters:

• key: Tekenreeks, niet gebruikt

Resultaten retourneren:

• Value, retourneert een waarde die JSON-serialiseerbaar bevat