   Serial.println(")");
 
   if(status==VALID) {
-    String topic = rfTopic + String("/recv/") + protocol;
+    String topic = globalTopic + String("/recv/") + protocol;
     if (deviceID != NULL) {
       topic += String('/') + deviceID;
     }

  strncpy(payload, (char *)payload_, length);
  payload[length]='\0';

  String sendTopic = rfTopic + "/send/";
  if(topic.startsWith(sendTopic)) {
    transmitt(topic.substring(sendTopic.length()), payload);
  }

      mqtt.subscribe((mainTopic + "/set/+").c_str());
      mqtt.subscribe((mainTopic + "/ota/+").c_str());
      mqtt.subscribe((mainTopic + "/send/+").c_str());
      mqtt.subscribe((globalTopic + "/send/+").c_str());
    } else {
      Serial.print("failed, rc=");
      Serial.print(mqtt.state());
