Package | Description |
---|---|
org.eclipse.paho.client.mqttv3 |
Contains a programming interface enabling applications to communicate with an MQTT server.
|
org.eclipse.paho.client.mqttv3.internal | |
org.eclipse.paho.client.mqttv3.internal.wire |
Modifier and Type | Method and Description |
---|---|
MqttWireMessage |
MqttToken.getResponse() |
MqttWireMessage |
IMqttToken.getResponse()
Returns the response wire message
|
Modifier and Type | Method and Description |
---|---|
protected MqttWireMessage |
ClientState.get()
This returns the next piece of work, ie message, for the CommsSender
to send over the network.
|
MqttWireMessage |
Token.getResponse() |
MqttWireMessage |
Token.getWireMessage() |
protected MqttWireMessage |
Token.waitForResponse()
Waits for the message delivery to complete, but doesn't throw an exception
in the case of a NACK.
|
protected MqttWireMessage |
Token.waitForResponse(long timeout) |
Modifier and Type | Method and Description |
---|---|
MqttToken |
CommsTokenStore.getToken(MqttWireMessage message)
Based on the message type that has just been received return the associated
token from the token store or null if one does not exist.
|
protected void |
Token.markComplete(MqttWireMessage msg,
MqttException ex)
Mark the token as complete and ready for users to be notified.
|
protected void |
ClientState.notifyReceivedMsg(MqttWireMessage message)
Called by the CommsReceiver when a message has been received.
|
protected void |
ClientState.notifyResult(MqttWireMessage ack,
MqttToken token,
MqttException ex) |
protected void |
ClientState.notifySent(MqttWireMessage message)
Called by the CommsSender when a message has been sent
|
MqttToken |
CommsTokenStore.removeToken(MqttWireMessage message) |
protected void |
CommsTokenStore.saveToken(MqttToken token,
MqttWireMessage message) |
void |
ClientState.send(MqttWireMessage message,
MqttToken token)
Submits a message for delivery.
|
void |
ClientComms.sendNoWait(MqttWireMessage message,
MqttToken token)
Sends a message to the broker if in connected state, but only waits for the message to be
stored, before returning.
|
Modifier and Type | Class and Description |
---|---|
class |
MqttAck
Abstract super-class of all acknowledgement messages.
|
class |
MqttConnack
An on-the-wire representation of an MQTT CONNACK.
|
class |
MqttConnect
An on-the-wire representation of an MQTT CONNECT message.
|
class |
MqttDisconnect
An on-the-wire representation of an MQTT DISCONNECT message.
|
class |
MqttPersistableWireMessage |
class |
MqttPingReq
An on-the-wire representation of an MQTT PINGREQ message.
|
class |
MqttPingResp
An on-the-wire representation of an MQTT PINGRESP.
|
class |
MqttPubAck
An on-the-wire representation of an MQTT PUBACK message.
|
class |
MqttPubComp
An on-the-wire representation of an MQTT PUBCOMP message.
|
class |
MqttPublish
An on-the-wire representation of an MQTT SEND message.
|
class |
MqttPubRec
An on-the-wire representation of an MQTT PUBREC message.
|
class |
MqttPubRel
An on-the-wire representation of an MQTT PUBREL message.
|
class |
MqttSuback
An on-the-wire representation of an MQTT SUBACK.
|
class |
MqttSubscribe
An on-the-wire representation of an MQTT SUBSCRIBE message.
|
class |
MqttUnsubAck
An on-the-wire representation of an MQTT UNSUBACK.
|
class |
MqttUnsubscribe
An on-the-wire representation of an MQTT UNSUBSCRIBE message.
|
Modifier and Type | Method and Description |
---|---|
static MqttWireMessage |
MqttWireMessage.createWireMessage(byte[] bytes) |
static MqttWireMessage |
MqttWireMessage.createWireMessage(MqttPersistable data) |
MqttWireMessage |
MqttInputStream.readMqttWireMessage()
Reads an
MqttWireMessage from the stream. |
Modifier and Type | Method and Description |
---|---|
void |
MqttOutputStream.write(MqttWireMessage message)
Writes an
MqttWireMessage to the stream. |
Copyright © 2018 Eclipse Paho. All rights reserved.