Uses of Class
org.eclipse.paho.client.mqttv3.MqttPersistenceException

Packages that use MqttPersistenceException

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
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

Modifier and Type	Method and Description
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(java.lang.String key) Returns whether or not data is persisted using the specified key.
MqttPersistable	MqttClientPersistence.get(java.lang.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().
java.util.Enumeration	MqttClientPersistence.keys() Returns an Enumeration over the keys in this persistent data store.
void	MqttClientPersistence.open(java.lang.String clientId, java.lang.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(java.lang.String topic, byte[] payload, int qos, boolean retained)
void	IMqttClient.publish(java.lang.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(java.lang.String topic, byte[] payload, int qos, boolean retained)
IMqttDeliveryToken	IMqttAsyncClient.publish(java.lang.String topic, byte[] payload, int qos, boolean retained) Publishes a message to a topic on 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.
void	MqttClient.publish(java.lang.String topic, MqttMessage message)
void	IMqttClient.publish(java.lang.String topic, MqttMessage message) Publishes a message to a topic on the server.
IMqttDeliveryToken	MqttAsyncClient.publish(java.lang.String topic, MqttMessage message)
IMqttDeliveryToken	IMqttAsyncClient.publish(java.lang.String topic, MqttMessage message) 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	MqttClientPersistence.put(java.lang.String key, MqttPersistable persistable) Puts the specified data into the persistent store.
void	MqttClientPersistence.remove(java.lang.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

Modifier and Type	Method and Description
void	ConnectActionListener.connect() Start the connect processing
void	ClientState.unPersistBufferedMessage(MqttWireMessage message)

Uses of MqttPersistenceException in org.eclipse.paho.client.mqttv3.internal.wire

Methods in org.eclipse.paho.client.mqttv3.internal.wire that throw MqttPersistenceException

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
void	MqttDefaultFilePersistence.clear()
void	MemoryPersistence.clear()
void	MqttDefaultFilePersistence.close()
void	MemoryPersistence.close()
boolean	MqttDefaultFilePersistence.containsKey(java.lang.String key)
boolean	MemoryPersistence.containsKey(java.lang.String key)
MqttPersistable	MqttDefaultFilePersistence.get(java.lang.String key)
MqttPersistable	MemoryPersistence.get(java.lang.String key)
java.util.Enumeration	MqttDefaultFilePersistence.keys() Returns all of the persistent data from the previously specified persistence directory.
java.util.Enumeration	MemoryPersistence.keys()
void	MqttDefaultFilePersistence.open(java.lang.String clientId, java.lang.String theConnection)
void	MemoryPersistence.open(java.lang.String clientId, java.lang.String serverURI)
void	MqttDefaultFilePersistence.put(java.lang.String key, MqttPersistable message) Writes the specified persistent data to the previously specified persistence directory.
void	MemoryPersistence.put(java.lang.String key, MqttPersistable persistable)
void	MqttDefaultFilePersistence.remove(java.lang.String key) Deletes the data with the specified key from the previously specified persistence directory.
void	MemoryPersistence.remove(java.lang.String key)