From cc8ace92f17c8e5aef7d68ff316e5cd038cd36b5 Mon Sep 17 00:00:00 2001
From: Nathan Lasseter <nathan@4574.co.uk>
Date: Wed, 22 May 2013 15:34:00 +0100
Subject: Initial Commit

---
 src/user4574/texttransport/AndroidPersistence.java | 50 ++++++++++++++++++++++
 1 file changed, 50 insertions(+)
 create mode 100644 src/user4574/texttransport/AndroidPersistence.java

(limited to 'src/user4574/texttransport/AndroidPersistence.java')

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);
+	}
+}
-- 
cgit v1.2.1