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 |
ClientComms.checkForActivity() |
MqttToken |
ClientState.checkForActivity()
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(String key) |
MqttToken |
CommsTokenStore.removeToken(MqttWireMessage message) |
MqttToken |
CommsTokenStore.removeToken(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.
|
protected void |
ClientState.notifyComplete(MqttToken token)
Called when waiters and callbacks have processed the message.
|
protected void |
ClientState.notifyResult(MqttWireMessage ack,
MqttToken token,
MqttException ex) |
protected void |
CommsTokenStore.saveToken(MqttToken token,
MqttWireMessage message) |
protected void |
CommsTokenStore.saveToken(MqttToken token,
String key) |
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,
Object userContext,
IMqttActionListener userCallback) |
Copyright © 2019 Eclipse Paho. All rights reserved.