From 5d14f1cc96a7ac749cdcba72a14d5f2825df37a9 Mon Sep 17 00:00:00 2001
From: Nathan Lasseter <nathan@4574.co.uk>
Date: Wed, 22 May 2013 17:23:10 +0100
Subject: Moved MqttCallback to new class. Added text boxes &
 connect/disconnect button.

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

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

diff --git a/src/user4574/texttransport/MqttMsgCallback.java b/src/user4574/texttransport/MqttMsgCallback.java
new file mode 100644
index 0000000..3755260
--- /dev/null
+++ b/src/user4574/texttransport/MqttMsgCallback.java
@@ -0,0 +1,25 @@
+package user4574.texttransport;
+
+import org.eclipse.paho.client.mqttv3.MqttCallback;
+import org.eclipse.paho.client.mqttv3.MqttDeliveryToken;
+import org.eclipse.paho.client.mqttv3.MqttMessage;
+import org.eclipse.paho.client.mqttv3.MqttTopic;
+
+import android.telephony.SmsManager;
+
+public class MqttMsgCallback implements MqttCallback {
+	
+	SmsManager sms;
+	
+	public MqttMsgCallback (SmsManager sms) {
+		this.sms = sms;
+	}
+	
+	public void connectionLost(Throwable exception) {}
+	public void deliveryComplete(MqttDeliveryToken token) {}
+	public void messageArrived(MqttTopic topic, MqttMessage message) throws Exception {
+		String[] topicarr = topic.getName().split("/");
+		sms.sendTextMessage(topicarr[2], null, message.toString(), null, null);
+	}
+
+}
-- 
cgit v1.2.1