Arduino - automatizare DIY

import android.app.IntentService;
import android.content.Context;
import android.content.Intent;
import android.support.annotation.Nullable;
import android.util.Log;
import android.widget.Toast;
import org.eclipse.paho.android.service.MqttAndroidClient;
import org.eclipse.paho.client.mqttv3.IMqttActionListener;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.IMqttToken;
import org.eclipse.paho.client.mqttv3.MqttCallbackExtended;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import static android.content.ContentValues.TAG;
/**
* Created by petre on 17-Dec-17.
*/
public class RecivePaho extends IntentService {
Context context;
MqttAndroidClient client;
IMqttToken token;
String topic = "test/proba";

private MqttConnectOptions getMqttConnectionOption() {
	 MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
	 mqttConnectOptions.setCleanSession(false);
	 mqttConnectOptions.setAutomaticReconnect(true);
	 //mqttConnectOptions.setUserName("username");
	 //mqttConnectOptions.setPassword("password".toCharArray());
	 return mqttConnectOptions;
}
public RecivePaho(){
	 super("RecivePaho");
}

@Override
public int onstartCommand(Intent intent, int flags, int startId) {
	 handleStart(intent
	 ,startId);
	 return START_STICKY;
}
void handleStart(Intent intent, int startId) {
	 lucramMosquitto();
}
public void lucramMosquitto(){
	 context=this;
	 String clientId = MqttClient.generateClientId();
	 System.out.println("A inceput");

	 client = new MqttAndroidClient(context, "tcp://ipul.brokerului.meu.x.x.x.x:1883", clientId);
		 System.out.println("cred ca e conectat");
		 try {
			 token = client.connect(getMqttConnectionOption(),null);
			 token.setActionCallback(new IMqttActionListener() {
				 @Override
				 public void onSuccess(IMqttToken asyncActionToken) {
					 System.out.println("S-a creat o conexiune de client ");
					 // We are connected
					 Log.d(TAG, "onSuccess");
					 primeste();
				 }
				 @Override
				 public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
					 // Something went wrong e.g. connection timeout or firewall problems
					 Log.d(TAG, "onFailure");
					 System.out.println("Nu m-am conectat cu serverul.");
				 }
			 });
		 } catch (MqttException e) {
			 e.printStackTrace();
		 }
	 }

	 public void primeste(){
		 int qos = 1;
		 try {
			 token = client.subscribe(topic, qos);
			 token.setActionCallback(new IMqttActionListener() {
				 @Override
				 public void onSuccess(IMqttToken asyncActionToken) {
					 // The message was published
					 Toast.makeText(context,"Conectat ",Toast.LENGTH_LONG).show();
					 System.out.println("S-a abonat cu succes la topic. ");
				 }
				 @Override
				 public void onFailure(IMqttToken asyncActionToken,
										 Throwable exception) {
					 // The subscription could not be performed, maybe the user was not
					 // authorized to subscribe on the specified topic e.g. using wildcards
					 System.out.println("Nu am reusit sa ma abonez la un subiect!!!!!!!!!!");
				 }
			 });
		 } catch (MqttException e) {
			 e.printStackTrace();
		 }
		 citesteM();
	 }

	 public void citesteM(){
		 client.setCallback(new MqttCallbackExtended() {
			 @Override
			 public void connectionLost(Throwable cause) {
				 System.out.println("S-a pierdut conexiunea!!!!!!!!!!!!!!!!!!!!!!!!!");
			 }
			 @Override
			 public void messageArrived(String topic, MqttMessage message) throws Exception {
				 Toast.makeText(context,message.toString(),Toast.LENGTH_LONG).show();
				 System.out.println("\n "+message.toString()+"\n");
			 }
			 @Override
			 public void deliveryComplete(IMqttDeliveryToken token) {
			 }
			 @Override
			 public void connectComplete(boolean reconnect, String serverURI) {
				 System.out.println(" RECONECT ================ "+reconnect+" Server URI"+serverURI);
			 }
		 });
	 }
@Override
protected void onHandleIntent(@Nullable Intent intent) {
	 lucramMosquitto();
}
}