speed matrix
This commit is contained in:
@@ -26,17 +26,16 @@ void callback(char *p_topic, byte *p_payload, unsigned int p_length)
|
||||
{
|
||||
|
||||
yield();
|
||||
DeserializationError err = deserializeJson(doc, String(payload));
|
||||
deserializeJson(doc, String(payload));
|
||||
yield();
|
||||
// if (err)
|
||||
// {
|
||||
// Serial.print(F("deserializeJson() failed with code "));
|
||||
// Serial.println(err.c_str());
|
||||
// }
|
||||
mensaje = doc["msg"].as<String>();
|
||||
R = doc["R"];
|
||||
G = doc["G"];
|
||||
B = doc["B"];
|
||||
matrix_speed = doc["speed"].as<int>();
|
||||
if(matrix_speed<50)
|
||||
matrix_speed=50;
|
||||
|
||||
texto = mensaje + " " + hora;
|
||||
x = matrix.width();
|
||||
longitud = texto.length() * 5 + 64;
|
||||
@@ -50,21 +49,24 @@ void reconnect()
|
||||
String clientId = "matrix_client-" + String(random(0xffff), HEX);
|
||||
if (client.connect(clientId.c_str(), MQTT_USER, MQTT_PASSWORD))
|
||||
{
|
||||
//Serial.println("INFO: connected");
|
||||
|
||||
client.subscribe(MQTT_TOPIC_FULL);
|
||||
}
|
||||
else
|
||||
{
|
||||
//Serial.print("ERROR: failed, rc=");
|
||||
//Serial.print(client.state());
|
||||
//Serial.println("DEBUG: try again in 5 seconds");
|
||||
mensaje = "ERROR AL CONECTAR SERVIDOR MQTT";
|
||||
texto = mensaje + " " + hora;
|
||||
x = matrix.width();
|
||||
longitud = texto.length() * 5 + 64;
|
||||
debug("Error conexion MQTT");
|
||||
|
||||
yield();
|
||||
delay(5000);
|
||||
yield();
|
||||
delay(1000);
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
void mqtt_init()
|
||||
{
|
||||
client.setServer(MQTT_SERVER_IP, MQTT_SERVER_PORT);
|
||||
|
||||
Reference in New Issue
Block a user