|
|
@@ -103,7 +103,7 @@ public class MqttFaultConsumer extends AbstractMqttConsumer {
|
|
103
|
103
|
});
|
|
104
|
104
|
}
|
|
105
|
105
|
|
|
106
|
|
- private void insertTdEngine(Map<String, Object> data, String topic) throws SQLException {
|
|
|
106
|
+ void insertTdEngine(Map<String, Object> data, String topic) throws SQLException {
|
|
107
|
107
|
|
|
108
|
108
|
String[] topicParts = topic.split("/");
|
|
109
|
109
|
if (topicParts.length < 2) {
|
|
|
@@ -127,7 +127,7 @@ public class MqttFaultConsumer extends AbstractMqttConsumer {
|
|
127
|
127
|
tdEngineAlarm.recordFailure(newMap, controllerName, table);
|
|
128
|
128
|
}
|
|
129
|
129
|
|
|
130
|
|
- private void triggermethod(String topic, SysFault weather) {
|
|
|
130
|
+ void triggermethod(String topic, SysFault weather) {
|
|
131
|
131
|
|
|
132
|
132
|
String deviceId = weather.getDevice_id();
|
|
133
|
133
|
String type = weather.getType();
|