|
|
|
@ -86,7 +86,7 @@ public class TbGetTelemetryNode implements TbNode { |
|
|
|
ListenableFuture<List<TsKvEntry>> list = ctx.getTimeseriesService().findAll(ctx.getTenantId(), msg.getOriginator(), queries); |
|
|
|
DonAsynchron.withCallback(list, data -> { |
|
|
|
process(data, msg); |
|
|
|
TbMsg newMsg = ctx.newMsg(msg.getType(), msg.getOriginator(), msg.getMetaData(), msg.getData()); |
|
|
|
TbMsg newMsg = ctx.transformMsg(msg, msg.getType(), msg.getOriginator(), msg.getMetaData(), msg.getData()); |
|
|
|
ctx.tellNext(newMsg, SUCCESS); |
|
|
|
}, error -> ctx.tellFailure(msg, error), ctx.getDbCallbackExecutor()); |
|
|
|
} catch (Exception e) { |
|
|
|
|