From cc8ace92f17c8e5aef7d68ff316e5cd038cd36b5 Mon Sep 17 00:00:00 2001 From: Nathan Lasseter Date: Wed, 22 May 2013 15:34:00 +0100 Subject: Initial Commit --- src/user4574/texttransport/Start.java | 41 +++++++++++++++++++++++++++++++++++ 1 file changed, 41 insertions(+) create mode 100644 src/user4574/texttransport/Start.java (limited to 'src/user4574/texttransport/Start.java') diff --git a/src/user4574/texttransport/Start.java b/src/user4574/texttransport/Start.java new file mode 100644 index 0000000..03ea032 --- /dev/null +++ b/src/user4574/texttransport/Start.java @@ -0,0 +1,41 @@ +package user4574.texttransport; + +import org.eclipse.paho.client.mqttv3.MqttCallback; +import org.eclipse.paho.client.mqttv3.MqttClient; +import org.eclipse.paho.client.mqttv3.MqttDeliveryToken; +import org.eclipse.paho.client.mqttv3.MqttException; +import org.eclipse.paho.client.mqttv3.MqttMessage; +import org.eclipse.paho.client.mqttv3.MqttTopic; + +import android.app.Activity; +import android.os.Bundle; +import android.telephony.SmsManager; + +public class Start extends Activity implements MqttCallback { + + public static MqttClient client; + private SmsManager sms = SmsManager.getDefault(); + + protected void onCreate(Bundle savedInstanceState) { + super.onCreate(savedInstanceState); + + try { + client = new MqttClient("tcp://192.168.0.222:1883", MqttClient.generateClientId(), new AndroidPersistence()); + client.setCallback(this); + client.connect(); + client.subscribe("/texttransport/+/send"); + } catch (MqttException e) { + e.printStackTrace(); + } + + setContentView(R.layout.start); + } + + 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); + } + +} \ No newline at end of file -- cgit v1.2.1