com.amazonaws.mobileconnectors.appsync.subscription.mqtt

Class AppSyncMqttPersistence

java.lang.Object

com.amazonaws.mobileconnectors.appsync.subscription.mqtt.AppSyncMqttPersistence

public class AppSyncMqttPersistence
extends java.lang.Object

An implementation of the MqttClientPersistence interface that provides file based persistence. A directory is specified when the Persistence object is created. When the persistence is then opened (see open(String, String)), a sub-directory is made beneath the base for this client ID and connection key. This allows one persistence base directory to be shared by multiple clients. The sub-directory's name is created from a concatenation of the client ID and connection key with any instance of '/', '\\', ':' or ' ' removed.

Constructor Summary

Constructors

Constructor and Description
AppSyncMqttPersistence()
AppSyncMqttPersistence(java.lang.String directory) Create an file-based persistent data store within the specified directory.

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AppSyncMqttPersistence

public AppSyncMqttPersistence()

AppSyncMqttPersistence

public AppSyncMqttPersistence(java.lang.String directory)

Create an file-based persistent data store within the specified directory.

Parameters:

directory - the directory to use.

Method Detail

open

public void open(java.lang.String clientId,
                 java.lang.String theConnection)
          throws MqttPersistenceException

Throws:

MqttPersistenceException

close

public void close()
           throws MqttPersistenceException

Throws:

MqttPersistenceException

put

public void put(java.lang.String key,
                MqttPersistable message)
         throws MqttPersistenceException

Writes the specified persistent data to the previously specified persistence directory. This method uses a safe overwrite policy to ensure IO errors do not lose messages.

Parameters:

message -

Throws:

MqttPersistenceException

get

public MqttPersistable get(java.lang.String key)
                    throws MqttPersistenceException

Throws:

MqttPersistenceException

remove

public void remove(java.lang.String key)
            throws MqttPersistenceException

Deletes the data with the specified key from the previously specified persistence directory.

Throws:

MqttPersistenceException

keys

public java.util.Enumeration keys()
                           throws MqttPersistenceException

Returns all of the persistent data from the previously specified persistence directory.

Returns:

all of the persistent data from the persistence directory.

Throws:

MqttPersistenceException

containsKey

public boolean containsKey(java.lang.String key)
                    throws MqttPersistenceException

Throws:

MqttPersistenceException

clear

public void clear()
           throws MqttPersistenceException

Throws:

MqttPersistenceException