 {
 
   Serial.print("Checking if state topic");
- // if(String(topic) == "ECS/state"){
 	  Serial.println("Received ECS/State change message");
 		 Serial.println("changing ECS relay state");
 	     if ((char)payload[0] == ECS_STATE_ON) {

		 }

	  
  //}
  //else {
  //	  Serial.println("not for me...");
  //}  

	
}

  myMqtt = new MqttConnection(SENSOR_ID, WLAN_SSID, WLAN_PASS, MQTT_SERVER, MQTT_PORT);
  myMqtt->registerCustomProcessing(&processEcsStateMsg);
  myMqtt->addSubscription("state");
 // myMqtt->addSubscription("force");  
  
  
}
