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 | Method and Description |
---|---|
IMqttActionListener |
IMqttToken.getActionCallback()
Return the async listener for this token.
|
IMqttActionListener |
MqttToken.getActionCallback() |
Modifier and Type | Method and Description |
---|---|
IMqttToken |
MqttAsyncClient.checkPing(java.lang.Object userContext,
IMqttActionListener callback) |
IMqttToken |
MqttAsyncClient.connect(MqttConnectOptions options,
java.lang.Object userContext,
IMqttActionListener callback) |
IMqttToken |
IMqttAsyncClient.connect(MqttConnectOptions options,
java.lang.Object userContext,
IMqttActionListener callback)
Connects to an MQTT server using the specified options.
|
IMqttToken |
MqttAsyncClient.connect(java.lang.Object userContext,
IMqttActionListener callback) |
IMqttToken |
IMqttAsyncClient.connect(java.lang.Object userContext,
IMqttActionListener callback)
Connects to an MQTT server using the default options.
|
IMqttToken |
MqttAsyncClient.disconnect(long quiesceTimeout,
java.lang.Object userContext,
IMqttActionListener callback) |
IMqttToken |
IMqttAsyncClient.disconnect(long quiesceTimeout,
java.lang.Object userContext,
IMqttActionListener callback)
Disconnects from the server.
|
IMqttToken |
MqttAsyncClient.disconnect(java.lang.Object userContext,
IMqttActionListener callback) |
IMqttToken |
IMqttAsyncClient.disconnect(java.lang.Object userContext,
IMqttActionListener callback)
Disconnects from the server.
|
IMqttDeliveryToken |
MqttAsyncClient.publish(java.lang.String topic,
byte[] payload,
int qos,
boolean retained,
java.lang.Object userContext,
IMqttActionListener callback) |
IMqttDeliveryToken |
IMqttAsyncClient.publish(java.lang.String topic,
byte[] payload,
int qos,
boolean retained,
java.lang.Object userContext,
IMqttActionListener callback)
Publishes a message to a topic on the server.
|
IMqttDeliveryToken |
MqttAsyncClient.publish(java.lang.String topic,
MqttMessage message,
java.lang.Object userContext,
IMqttActionListener callback) |
IMqttDeliveryToken |
IMqttAsyncClient.publish(java.lang.String topic,
MqttMessage message,
java.lang.Object userContext,
IMqttActionListener callback)
Publishes a message to a topic on the server.
|
void |
IMqttToken.setActionCallback(IMqttActionListener listener)
Register a listener to be notified when an action completes.
|
void |
MqttToken.setActionCallback(IMqttActionListener listener) |
IMqttToken |
MqttAsyncClient.subscribe(java.lang.String[] topicFilters,
int[] qos,
java.lang.Object userContext,
IMqttActionListener callback) |
IMqttToken |
IMqttAsyncClient.subscribe(java.lang.String[] topicFilters,
int[] qos,
java.lang.Object userContext,
IMqttActionListener callback)
Subscribes to multiple topics, each of which may include wildcards.
|
IMqttToken |
MqttAsyncClient.subscribe(java.lang.String[] topicFilters,
int[] qos,
java.lang.Object userContext,
IMqttActionListener callback,
IMqttMessageListener[] messageListeners) |
IMqttToken |
IMqttAsyncClient.subscribe(java.lang.String[] topicFilters,
int[] qos,
java.lang.Object userContext,
IMqttActionListener callback,
IMqttMessageListener[] messageListeners)
Subscribe to multiple topics, each of which may include wildcards.
|
IMqttToken |
MqttAsyncClient.subscribe(java.lang.String topicFilter,
int qos,
java.lang.Object userContext,
IMqttActionListener callback) |
IMqttToken |
IMqttAsyncClient.subscribe(java.lang.String topicFilter,
int qos,
java.lang.Object userContext,
IMqttActionListener callback)
Subscribe to a topic, which may include wildcards.
|
IMqttToken |
MqttAsyncClient.subscribe(java.lang.String topicFilter,
int qos,
java.lang.Object userContext,
IMqttActionListener callback,
IMqttMessageListener messageListener) |
IMqttToken |
IMqttAsyncClient.subscribe(java.lang.String topicFilter,
int qos,
java.lang.Object userContext,
IMqttActionListener callback,
IMqttMessageListener messageListener)
Subscribe to a topic, which may include wildcards.
|
IMqttToken |
MqttAsyncClient.unsubscribe(java.lang.String[] topicFilters,
java.lang.Object userContext,
IMqttActionListener callback) |
IMqttToken |
IMqttAsyncClient.unsubscribe(java.lang.String[] topicFilters,
java.lang.Object userContext,
IMqttActionListener callback)
Requests the server unsubscribe the client from one or more topics.
|
IMqttToken |
MqttAsyncClient.unsubscribe(java.lang.String topicFilter,
java.lang.Object userContext,
IMqttActionListener callback) |
IMqttToken |
IMqttAsyncClient.unsubscribe(java.lang.String topicFilter,
java.lang.Object userContext,
IMqttActionListener callback)
Requests the server unsubscribe the client from a topics.
|
Modifier and Type | Class and Description |
---|---|
class |
ConnectActionListener
This class handles the connection of the AsyncClient to one of the available URLs.
|
Modifier and Type | Method and Description |
---|---|
IMqttActionListener |
Token.getActionCallback() |
Modifier and Type | Method and Description |
---|---|
MqttToken |
ClientComms.checkForActivity(IMqttActionListener pingCallback) |
MqttToken |
ClientState.checkForActivity(IMqttActionListener pingCallback)
Check and send a ping if needed and check for ping timeout.
|
void |
Token.setActionCallback(IMqttActionListener listener) |
Constructor and Description |
---|
ConnectActionListener(MqttAsyncClient client,
MqttClientPersistence persistence,
ClientComms comms,
MqttConnectOptions options,
MqttToken userToken,
java.lang.Object userContext,
IMqttActionListener userCallback,
boolean reconnect) |