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 | Interface and Description |
---|---|
interface |
IMqttDeliveryToken
Provides a mechanism for tracking the delivery of a message.
|
Modifier and Type | Class and Description |
---|---|
class |
MqttDeliveryToken
Provides a mechanism to track the delivery progress of a message.
|
class |
MqttToken
Provides a mechanism for tracking the completion of an asynchronous action.
|
Modifier and Type | Method and Description |
---|---|
IMqttToken |
MqttAsyncClient.checkPing(java.lang.Object userContext,
IMqttActionListener callback) |
IMqttToken |
MqttAsyncClient.connect() |
IMqttToken |
IMqttAsyncClient.connect()
Connects to an MQTT server using the default options.
|
IMqttToken |
MqttAsyncClient.connect(MqttConnectOptions options) |
IMqttToken |
IMqttAsyncClient.connect(MqttConnectOptions options)
Connects to an MQTT server using the provided connect options.
|
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 |
MqttClient.connectWithResult(MqttConnectOptions options) |
IMqttToken |
IMqttClient.connectWithResult(MqttConnectOptions options)
Connects to an MQTT server using the specified options.
|
IMqttToken |
MqttAsyncClient.disconnect() |
IMqttToken |
IMqttAsyncClient.disconnect()
Disconnects from the server.
|
IMqttToken |
MqttAsyncClient.disconnect(long quiesceTimeout) |
IMqttToken |
IMqttAsyncClient.disconnect(long quiesceTimeout)
Disconnects from the server.
|
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.
|
IMqttToken |
MqttAsyncClient.subscribe(java.lang.String[] topicFilters,
int[] qos) |
IMqttToken |
IMqttAsyncClient.subscribe(java.lang.String[] topicFilters,
int[] qos)
Subscribe to multiple topics, each of which may include wildcards.
|
IMqttToken |
MqttAsyncClient.subscribe(java.lang.String[] topicFilters,
int[] qos,
IMqttMessageListener[] messageListeners) |
IMqttToken |
IMqttAsyncClient.subscribe(java.lang.String[] topicFilters,
int[] qos,
IMqttMessageListener[] messageListeners)
Subscribe to multiple topics, each of which may include wildcards.
|
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) |
IMqttToken |
IMqttAsyncClient.subscribe(java.lang.String topicFilter,
int qos)
Subscribe to a topic, which may include wildcards.
|
IMqttToken |
MqttAsyncClient.subscribe(java.lang.String topicFilter,
int qos,
IMqttMessageListener messageListener) |
IMqttToken |
IMqttAsyncClient.subscribe(java.lang.String topicFilter,
int qos,
IMqttMessageListener messageListener)
Subscribe to a topic, 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 topicFilter) |
IMqttToken |
IMqttAsyncClient.unsubscribe(java.lang.String topicFilter)
Requests the server unsubscribe the client from a topic.
|
IMqttToken |
MqttAsyncClient.unsubscribe(java.lang.String[] topicFilters) |
IMqttToken |
IMqttAsyncClient.unsubscribe(java.lang.String[] topicFilters)
Requests the server unsubscribe the client from one or more topics.
|
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 | Method and Description |
---|---|
void |
IMqttActionListener.onFailure(IMqttToken asyncActionToken,
java.lang.Throwable exception)
This method is invoked when an action fails.
|
void |
IMqttActionListener.onSuccess(IMqttToken asyncActionToken)
This method is invoked when an action has completed successfully.
|
Modifier and Type | Method and Description |
---|---|
void |
ConnectActionListener.onFailure(IMqttToken token,
java.lang.Throwable exception)
The connect failed, so try the next URI on the list.
|
void |
ConnectActionListener.onSuccess(IMqttToken token)
If the connect succeeded then call the users onSuccess callback
|