Browse Source

fix TbGetTelemetryNode (#1377)

* fix TbGetTelemetryNode

* refactoring ui TbGetTelemetryNode

* update license header

* refactoring TbGetTelemetryNode

* fix imports and update license header

* refactoring TbGetTelemetryNode

* replace typo

* fix TbGetTelemetryNode

* fix TbGetTelemetryNode

* fix TbGetTelemetryNode
pull/1385/head
ShvaykaD 8 years ago
committed by Valerii Sosliuk
parent
commit
4a1916668a
  1. 4
      rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/metadata/TbGetTelemetryNode.java

4
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/metadata/TbGetTelemetryNode.java

@ -88,7 +88,9 @@ public class TbGetTelemetryNode implements TbNode {
ctx.tellFailure(msg, new IllegalStateException("Telemetry is not selected!")); ctx.tellFailure(msg, new IllegalStateException("Telemetry is not selected!"));
} else { } else {
try { try {
checkMetadataKeyPatterns(msg); if (config.isUseMetadataIntervalPatterns()) {
checkMetadataKeyPatterns(msg);
}
ListenableFuture<List<TsKvEntry>> list = ctx.getTimeseriesService().findAll(ctx.getTenantId(), msg.getOriginator(), buildQueries(msg)); ListenableFuture<List<TsKvEntry>> list = ctx.getTimeseriesService().findAll(ctx.getTenantId(), msg.getOriginator(), buildQueries(msg));
DonAsynchron.withCallback(list, data -> { DonAsynchron.withCallback(list, data -> {
process(data, msg); process(data, msg);

Loading…
Cancel
Save