double receive a toggle command? about umqttbroker HOT 7 CLOSED

/*
 * uMQTTBroker demo for Arduino (C++-style)
 * 
 * The program defines a custom broker class with callbacks, 
 * starts it, subscribes locally to anything, and publishs a topic every second.
 * Try to connect from a remote client and publish something - the console will show this as well.
 */

#include <ESP8266WiFi.h>
#include "uMQTTBroker.h"

/*
 * Your WiFi config here
 */
char host[] = "ESP-MQTT";           // Hostname & SSID in AP-Mode
char ssid[] = "DEG-TEST-WLAN";      // your network SSID (name)
char pass[] = "12345678";           // your network password
bool WiFiAP = false;      // Do yo want the ESP as AP?
bool STATIC = true;                 // Static IP for STA Mode?
IPAddress ip(192,168,1,200);        // Static IP
IPAddress gw(192,168,1,1);          // Static Gateway/DNS
IPAddress su(255,255,255,0);        // Static Subnet Mask

/*
 * Custom broker class with overwritten callback functions
 */
class myMQTTBroker: public uMQTTBroker
{
public:
    virtual bool onConnect(IPAddress addr, uint16_t client_count) {
      Serial.println(addr.toString()+" connected");
      return true;
    }
    
    virtual bool onAuth(String username, String password) {
      Serial.println("Username/Password: "+username+"/"+password);
      return true;
    }
    
    virtual void onData(String topic, const char *data, uint32_t length) {
      char data_str[length+1];
      os_memcpy(data_str, data, length);
      data_str[length] = '\0';
      
      Serial.println("received topic '"+topic+"' with data '"+(String)data_str+"'");
    }
};

myMQTTBroker myBroker;

/*
 * WiFi init stuff
 */
void startWiFiClient()
{
  if (STATIC) {
	WiFi.config(ip, gw, gw, su);
  }
  WiFi.softAPdisconnect(true);
  WiFi.hostname(host);
  Serial.println("Connecting to "+(String)ssid);
  WiFi.begin(ssid, pass);
  
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("");
  Serial.println(""); 
  Serial.println("WiFi connected");
  Serial.println("IP address: " + WiFi.localIP().toString());
  Serial.println(""); 
}

void startWiFiAP()
{
  WiFi.softAP(ssid, pass);
  Serial.println("AP started");
  Serial.println("IP address: " + WiFi.softAPIP().toString());
}

void setup()
{
  Serial.begin(115200);
  Serial.println();
  Serial.println();

  // Start WiFi
  if (WiFiAP)
    startWiFiAP();
  else
    startWiFiClient();

  // Start the broker
  Serial.println("Starting MQTT broker");
  myBroker.init();

/*
 * Subscribe to anything
 */
  myBroker.subscribe("#");
}

//int counter = 0;

void loop()
{
/*
 * Publish the counter value as String
 */
  //myBroker.publish("broker/counter", (String)counter++);
   
  // wait a second
  delay(1000);
}

00:00:16 SRC: MQTT
00:00:16 RSL: Gruppe 0, Index 1, Befehl POWER, Daten off
00:00:16 MQT: stat/TEST/RESULT = {"POWER":"OFF"}
00:00:16 MQT: stat/TEST/POWER = OFF
00:00:16 SRC: MQTT
00:00:16 RSL: Gruppe 0, Index 1, Befehl POWER, Daten off
00:00:17 MQT: stat/TEST/RESULT = {"POWER":"OFF"}
00:00:17 MQT: stat/TEST/POWER = OFF