|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MqttPersistenceException | |
---|---|
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 | |
org.eclipse.paho.client.mqttv3.persist | Contains implementations of the MqttClientPersistence interface. |
Uses of MqttPersistenceException in org.eclipse.paho.client.mqttv3 |
---|
Methods in org.eclipse.paho.client.mqttv3 that throw MqttPersistenceException | |
---|---|
void |
MqttClientPersistence.clear()
Clears persistence, so that it no longer contains any persisted data. |
void |
MqttClientPersistence.close()
Close the persistent store that was previously opened. |
boolean |
MqttClientPersistence.containsKey(String key)
Returns whether or not data is persisted using the specified key. |
MqttPersistable |
MqttClientPersistence.get(String key)
Gets the specified data out of the persistent store. |
byte[] |
MqttPersistable.getHeaderBytes()
Returns the header bytes in an array. |
int |
MqttPersistable.getHeaderLength()
Returns the length of the header. |
int |
MqttPersistable.getHeaderOffset()
Returns the offset of the header within the byte array returned by MqttPersistable.getHeaderBytes() . |
byte[] |
MqttPersistable.getPayloadBytes()
Returns the payload bytes in an array. |
int |
MqttPersistable.getPayloadLength()
Returns the length of the payload. |
int |
MqttPersistable.getPayloadOffset()
Returns the offset of the payload within the byte array returned by MqttPersistable.getPayloadBytes() . |
Enumeration |
MqttClientPersistence.keys()
Returns an Enumeration over the keys in this persistent data store. |
void |
MqttClientPersistence.open(String clientId,
String serverURI)
Initialise the persistent store. |
MqttDeliveryToken |
MqttTopic.publish(byte[] payload,
int qos,
boolean retained)
Publishes a message on the topic. |
MqttDeliveryToken |
MqttTopic.publish(MqttMessage message)
Publishes the specified message to this topic, but does not wait for delivery of the message to complete. |
void |
MqttClient.publish(String topic,
byte[] payload,
int qos,
boolean retained)
|
IMqttDeliveryToken |
IMqttAsyncClient.publish(String topic,
byte[] payload,
int qos,
boolean retained)
Publishes a message to a topic on the server. |
void |
IMqttClient.publish(String topic,
byte[] payload,
int qos,
boolean retained)
Publishes a message to a topic on the server and return once it is delivered. |
IMqttDeliveryToken |
MqttAsyncClient.publish(String topic,
byte[] payload,
int qos,
boolean retained)
|
IMqttDeliveryToken |
IMqttAsyncClient.publish(String topic,
byte[] payload,
int qos,
boolean retained,
Object userContext,
IMqttActionListener callback)
Publishes a message to a topic on the server. |
IMqttDeliveryToken |
MqttAsyncClient.publish(String topic,
byte[] payload,
int qos,
boolean retained,
Object userContext,
IMqttActionListener callback)
|
void |
MqttClient.publish(String topic,
MqttMessage message)
|
IMqttDeliveryToken |
IMqttAsyncClient.publish(String topic,
MqttMessage message)
Publishes a message to a topic on the server. |
void |
IMqttClient.publish(String topic,
MqttMessage message)
Publishes a message to a topic on the server. |
IMqttDeliveryToken |
MqttAsyncClient.publish(String topic,
MqttMessage message)
|
IMqttDeliveryToken |
IMqttAsyncClient.publish(String topic,
MqttMessage message,
Object userContext,
IMqttActionListener callback)
Publishes a message to a topic on the server. |
IMqttDeliveryToken |
MqttAsyncClient.publish(String topic,
MqttMessage message,
Object userContext,
IMqttActionListener callback)
|
void |
MqttClientPersistence.put(String key,
MqttPersistable persistable)
Puts the specified data into the persistent store. |
void |
MqttClientPersistence.remove(String key)
Remove the data for the specified key. |
Uses of MqttPersistenceException in org.eclipse.paho.client.mqttv3.internal |
---|
Methods in org.eclipse.paho.client.mqttv3.internal that throw MqttPersistenceException | |
---|---|
void |
ConnectActionListener.connect()
The connect failed, so try the next URI on the list. |
protected void |
ClientState.deliveryComplete(MqttPublish message)
|
protected void |
ClientComms.deliveryComplete(MqttPublish msg)
|
protected void |
ClientState.undo(MqttPublish message)
This removes the MqttSend message from the outbound queue and persistence. |
Uses of MqttPersistenceException in org.eclipse.paho.client.mqttv3.internal.wire |
---|
Methods in org.eclipse.paho.client.mqttv3.internal.wire that throw MqttPersistenceException | |
---|---|
byte[] |
MqttPersistableWireMessage.getHeaderBytes()
|
int |
MqttPersistableWireMessage.getHeaderLength()
|
int |
MqttPersistableWireMessage.getHeaderOffset()
|
byte[] |
MqttPersistableWireMessage.getPayloadBytes()
|
int |
MqttPersistableWireMessage.getPayloadLength()
|
int |
MqttPersistableWireMessage.getPayloadOffset()
|
Uses of MqttPersistenceException in org.eclipse.paho.client.mqttv3.persist |
---|
Methods in org.eclipse.paho.client.mqttv3.persist that throw MqttPersistenceException | |
---|---|
void |
MqttDefaultFilePersistence.clear()
|
void |
MemoryPersistence.clear()
|
void |
MqttDefaultFilePersistence.close()
|
void |
MemoryPersistence.close()
|
boolean |
MqttDefaultFilePersistence.containsKey(String key)
|
boolean |
MemoryPersistence.containsKey(String key)
|
MqttPersistable |
MqttDefaultFilePersistence.get(String key)
|
MqttPersistable |
MemoryPersistence.get(String key)
|
Enumeration |
MqttDefaultFilePersistence.keys()
Returns all of the persistent data from the previously specified persistence directory. |
Enumeration |
MemoryPersistence.keys()
|
void |
MqttDefaultFilePersistence.open(String clientId,
String theConnection)
|
void |
MemoryPersistence.open(String clientId,
String serverURI)
|
void |
MqttDefaultFilePersistence.put(String key,
MqttPersistable message)
Writes the specified persistent data to the previously specified persistence directory. |
void |
MemoryPersistence.put(String key,
MqttPersistable persistable)
|
void |
MqttDefaultFilePersistence.remove(String key)
Deletes the data with the specified key from the previously specified persistence directory. |
void |
MemoryPersistence.remove(String key)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |