public class MqttPacketOutputStream
extends java.io.ByteArrayOutputStream
OutputStream
for MQTT packet with a flush method that
sends the packet.Constructor and Description |
---|
MqttPacketOutputStream(java.lang.String topic,
IMqttAsyncClient mqttClient,
int qos,
boolean retained) |
Modifier and Type | Method and Description |
---|---|
void |
flush() |
public MqttPacketOutputStream(java.lang.String topic, IMqttAsyncClient mqttClient, int qos, boolean retained)
topic
- MQTT TopicmqttClient
- MQTT Clientqos
- MQTT QOSretained
- MQTT retained flag