1 files changed, 50 insertions, 0 deletions
diff --git a/src/user4574/texttransport/AndroidPersistence.java b/src/user4574/texttransport/AndroidPersistence.java
new file mode 100644
index 0000000..66f9dd3
--- /dev/null
+++ b/src/user4574/texttransport/AndroidPersistence.java
@@ -0,0 +1,50 @@
+package user4574.texttransport;
+
+import java.util.Enumeration;
+import java.util.HashMap;
+import java.util.Vector;
+
+import org.eclipse.paho.client.mqttv3.MqttClientPersistence;
+import org.eclipse.paho.client.mqttv3.MqttPersistable;
+import org.eclipse.paho.client.mqttv3.MqttPersistenceException;
+
+public class AndroidPersistence implements MqttClientPersistence {
+	
+	private HashMap<String, MqttPersistable> store;
+	
+	public AndroidPersistence() {
+		store = new HashMap<String, MqttPersistable>();
+	}
+
+	public void clear() throws MqttPersistenceException {
+		store.clear();
+	}
+
+	public void close() throws MqttPersistenceException {
+		store = null;
+	}
+
+	public boolean containsKey(String arg0) throws MqttPersistenceException {
+		return store.containsKey(arg0);
+	}
+
+	public MqttPersistable get(String arg0) throws MqttPersistenceException {
+		return store.get(arg0);
+	}
+
+	public Enumeration<String> keys() throws MqttPersistenceException {
+		return new Vector<String>(store.keySet()).elements();
+	}
+
+	public void open(String arg0, String arg1) throws MqttPersistenceException {
+		store = new HashMap<String, MqttPersistable>();
+	}
+
+	public void put(String arg0, MqttPersistable arg1) throws MqttPersistenceException {
+		store.put(arg0, arg1);
+	}
+
+	public void remove(String arg0) throws MqttPersistenceException {
+		store.remove(arg0);
+	}
+}