|
@@ -22,7 +22,7 @@ public class TestUpConsumer implements MqttConsumer {
|
|
log.info("测试数据:{}", payload);
|
|
log.info("测试数据:{}", payload);
|
|
JSONObject jsonObject = JSONUtil.parseObj(payload);
|
|
JSONObject jsonObject = JSONUtil.parseObj(payload);
|
|
String deviceId = jsonObject.getStr("deviceId");
|
|
String deviceId = jsonObject.getStr("deviceId");
|
|
- mqttProducer.sendToMqtt(payload, String.format("%s_test_down", deviceId));
|
|
|
|
|
|
+ mqttProducer.sendToMqtt(payload, String.format("%s-test-down", deviceId));
|
|
return true;
|
|
return true;
|
|
}
|
|
}
|
|
}
|
|
}
|