unsub & sub

scenariMicroservizio/src/scenari/Scenari.java

@@ -175,6 +175,8 @@ public class Scenari {
 		JSONObject config = new JSONObject(Helper.leggiFile(FILE_ZONA));
 		config.put("attiva-scenari", attivaScenari);
 		Helper.scriviFile(config, FILE_ZONA);
+		mqttClient.unsubscribeTopic(Scenari.getMqttTree("from/","/gpio/" + this.attivaScenari);
+		mqttClient.subscribe(Scenari.getMqttTree("from/","gpio/"+attivaScenari);
 		this.attivaScenari = attivaScenari;
 	}
 
@@ -189,6 +191,8 @@ public class Scenari {
 		JSONObject config = new JSONObject(Helper.leggiFile(FILE_ZONA));
 		config.put("luce-antifurto", luceAntifurto);
 		Helper.scriviFile(config, FILE_ZONA);
+		mqttClient.unsubscribeTopic(Scenari.getMqttTree("from/","/gpio/" + this.luceAntifurto);
+		mqttClient.subscribe(Scenari.getMqttTree("from/","gpio/"+luceAntifurto);
 		this.luceAntifurto = luceAntifurto;
 	}
 
@@ -199,6 +203,8 @@ public class Scenari {
 		JSONObject config = new JSONObject(Helper.leggiFile(FILE_ZONA));
 		config.put("learn-trigger", learnTrigger);
 		Helper.scriviFile(config, FILE_ZONA);
+		mqttClient.unsubscribeTopic(Scenari.getMqttTree("from/","/gpio/" + this.learnTrigger);
+		mqttClient.subscribe(Scenari.getMqttTree("from/","gpio/"+learnTrigger);
 		this.learnTrigger = learnTrigger;
 	}