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 |
Modifier and Type | Class and Description |
---|---|
class |
MqttDeliveryToken
Provides a mechanism to track the delivery progress of a message.
|
Modifier and Type | Method and Description |
---|---|
MqttToken |
BufferedMessage.getToken() |
Constructor and Description |
---|
BufferedMessage(MqttWireMessage message,
MqttToken token) |
Modifier and Type | Method and Description |
---|---|
MqttToken |
ClientComms.checkForActivity() |
MqttToken |
ClientComms.checkForActivity(IMqttActionListener pingCallback) |
MqttToken |
ClientState.checkForActivity(IMqttActionListener pingCallback)
Check and send a ping if needed and check for ping timeout.
|
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.
|
MqttToken |
CommsTokenStore.getToken(java.lang.String key) |
MqttToken |
CommsTokenStore.removeToken(MqttWireMessage message) |
MqttToken |
CommsTokenStore.removeToken(java.lang.String key) |
Modifier and Type | Method and Description |
---|---|
void |
CommsCallback.asyncOperationComplete(MqttToken token) |
void |
ClientComms.connect(MqttConnectOptions options,
MqttToken token)
Sends a connect message and waits for an ACK or NACK.
|
void |
ClientComms.disconnect(MqttDisconnect disconnect,
long quiesceTimeout,
MqttToken token) |
void |
CommsCallback.fireActionEvent(MqttToken token)
An action has completed - if a completion listener has been set on the
token then invoke it with the outcome of the action.
|
void |
DisconnectedMessageBuffer.putMessage(MqttWireMessage message,
MqttToken token)
This will add a new message to the offline buffer,
if the buffer is full and deleteOldestMessages is enabled
then the 0th item in the buffer will be deleted and the
new message will be added.
|
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.
|
void |
ClientComms.shutdownConnection(MqttToken token,
MqttException reason)
Shuts down the connection to the server.
|
Constructor and Description |
---|
ConnectActionListener(MqttAsyncClient client,
MqttClientPersistence persistence,
ClientComms comms,
MqttConnectOptions options,
MqttToken userToken,
java.lang.Object userContext,
IMqttActionListener userCallback,
boolean reconnect) |