@ -29,7 +29,7 @@ public interface TbNode {
void onMsg(TbContext ctx, TbMsg msg) throws ExecutionException, InterruptedException, TbNodeException;
void destroy();
default void destroy() {}
default void onPartitionChangeMsg(TbContext ctx, PartitionChangeMsg msg) {}
@ -92,6 +92,9 @@ public abstract class TbAbstractCustomerActionNode<C extends TbAbstractCustomerA
@Override
public void destroy() {
if (customerIdCache != null) {
customerIdCache.invalidateAll();
}
@Data
@ -88,6 +88,9 @@ public abstract class TbAbstractRelationActionNode<C extends TbAbstractRelationA
if (entityIdCache != null) {
entityIdCache.invalidateAll();
protected ListenableFuture<RelationContainer> processEntityRelationAction(TbContext ctx, TbMsg msg, String relationType) {
@ -158,7 +158,4 @@ public class TbCopyAttributesToEntityViewNode implements TbNode {
return CollectionsUtil.contains(keys, attrKey);
@ -98,7 +98,4 @@ public class TbMsgCountNode implements TbNode {
ctx.tellSelf(tickMsg, curDelay);
@ -71,10 +71,6 @@ public abstract class AbstractTbMsgPushNode<T extends BaseTbMsgPushNodeConfigura
protected S buildEvent(TbMsg msg, TbContext ctx) {
String msgType = msg.getType();
if (DataConstants.ALARM.equals(msgType)) {
@ -93,7 +93,4 @@ public class TbCheckAlarmStatusNode implements TbNode {
@ -68,10 +68,6 @@ public class TbCheckMessageNode implements TbNode {
private boolean allKeysData(TbMsg msg) {
if (!messageNamesList.isEmpty()) {
Map<String, String> dataMap = dataToMap(msg);
@ -103,8 +103,4 @@ public class TbCheckRelationNode implements TbNode {
@ -52,8 +52,4 @@ public class TbMsgTypeFilterNode implements TbNode {
ctx.tellNext(msg, config.getMessageTypes().contains(msg.getType()) ? "True" : "False");
@ -117,8 +117,4 @@ public class TbMsgTypeSwitchNode implements TbNode {
ctx.tellNext(msg, relationType);
@ -51,8 +51,4 @@ public class TbOriginatorTypeFilterNode implements TbNode {
ctx.tellNext(msg, config.getOriginatorTypes().contains(originatorType) ? "True" : "False");
@ -90,8 +90,4 @@ public class TbOriginatorTypeSwitchNode implements TbNode {
@ -51,7 +51,4 @@ public class TbAckNode implements TbNode {
ctx.tellSuccess(msg);
@ -54,7 +54,4 @@ public class TbCheckpointNode implements TbNode {
ctx.enqueueForTellNext(msg, queueName, TbRelationTypes.SUCCESS, () -> ctx.ack(msg), error -> ctx.tellFailure(msg, error));
@ -63,7 +63,4 @@ public class TbRuleChainInputNode implements TbNode {
ctx.input(msg, ruleChainId);
@ -51,7 +51,4 @@ public class TbRuleChainOutputNode implements TbNode {
ctx.output(msg, ctx.getSelf().getName());
@ -148,9 +148,4 @@ public abstract class AbstractGeofencingNode<T extends TbGpsGeofencingFilterNode
return value;
@ -110,8 +110,4 @@ public class TbMsgToEmailNode implements TbNode {
@ -107,10 +107,6 @@ public class TbSendEmailNode implements TbNode {
private JavaMailSenderImpl createMailSender() {
JavaMailSenderImpl mailSender = new JavaMailSenderImpl();
mailSender.setHost(this.config.getSmtpHost());
@ -79,10 +79,6 @@ public abstract class TbAbstractGetAttributesNode<C extends TbGetAttributesNodeC
protected abstract ListenableFuture<T> findEntityIdAsync(TbContext ctx, TbMsg msg);
private void safePutAttributes(TbContext ctx, TbMsg msg, T entityId) {
@ -63,10 +63,6 @@ public abstract class TbAbstractGetEntityDetailsNode<C extends TbAbstractGetEnti
t -> ctx.tellFailure(msg, t), ctx.getDbCallbackExecutor());
protected abstract C loadGetEntityDetailsNodeConfiguration(TbNodeConfiguration configuration) throws TbNodeException;
protected abstract ListenableFuture<TbMsg> getDetails(TbContext ctx, TbMsg msg);
@ -100,11 +100,6 @@ public abstract class TbEntityGetAttrNode<T extends EntityId> implements TbNode
protected abstract ListenableFuture<T> findEntityAsync(TbContext ctx, EntityId originator);
public void setConfig(TbGetEntityAttrNodeConfiguration config) {
@ -80,8 +80,4 @@ public class TbGetOriginatorFieldsNode implements TbNode {
@ -125,10 +125,6 @@ public class TbGetTelemetryNode implements TbNode {
private List<ReadTsKvQuery> buildQueries(TbMsg msg, List<String> keys) {
final Interval interval = getInterval(msg);
final long aggIntervalStep = Aggregation.NONE.equals(aggregation) ? 1 :
@ -70,8 +70,4 @@ public class TbSendRPCReplyNode implements TbNode {
@ -75,8 +75,4 @@ public class TbMsgAttributesNode implements TbNode {
);
@ -49,8 +49,4 @@ public class TbSynchronizationBeginNode implements TbNode {
@ -48,7 +48,4 @@ public class TbSynchronizationEndNode implements TbNode {
@ -108,8 +108,4 @@ public class TbChangeOriginatorNode extends TbAbstractTransformNode {