diff options
Diffstat (limited to 'src/user4574/texttransport/Start.java')
| -rw-r--r-- | src/user4574/texttransport/Start.java | 41 |
1 files changed, 41 insertions, 0 deletions
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 |