|
|
@ -18,7 +18,6 @@ package org.thingsboard.rule.engine.geo; |
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
import org.thingsboard.rule.engine.api.RuleNode; |
|
|
import org.thingsboard.rule.engine.api.RuleNode; |
|
|
import org.thingsboard.rule.engine.api.TbContext; |
|
|
import org.thingsboard.rule.engine.api.TbContext; |
|
|
import org.thingsboard.rule.engine.api.TbNodeConfiguration; |
|
|
|
|
|
import org.thingsboard.rule.engine.api.TbNodeException; |
|
|
import org.thingsboard.rule.engine.api.TbNodeException; |
|
|
import org.thingsboard.server.common.data.msg.TbNodeConnectionType; |
|
|
import org.thingsboard.server.common.data.msg.TbNodeConnectionType; |
|
|
import org.thingsboard.server.common.data.plugin.ComponentType; |
|
|
import org.thingsboard.server.common.data.plugin.ComponentType; |
|
|
@ -65,11 +64,6 @@ import org.thingsboard.server.common.msg.TbMsg; |
|
|
configDirective = "tbFilterNodeGpsGeofencingConfig") |
|
|
configDirective = "tbFilterNodeGpsGeofencingConfig") |
|
|
public class TbGpsGeofencingFilterNode extends AbstractGeofencingNode<TbGpsGeofencingFilterNodeConfiguration> { |
|
|
public class TbGpsGeofencingFilterNode extends AbstractGeofencingNode<TbGpsGeofencingFilterNodeConfiguration> { |
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
|
public void init(TbContext ctx, TbNodeConfiguration configuration) throws TbNodeException { |
|
|
|
|
|
super.init(ctx, configuration); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
@Override |
|
|
public void onMsg(TbContext ctx, TbMsg msg) throws TbNodeException { |
|
|
public void onMsg(TbContext ctx, TbMsg msg) throws TbNodeException { |
|
|
ctx.tellNext(msg, checkMatches(msg) ? TbNodeConnectionType.TRUE : TbNodeConnectionType.FALSE); |
|
|
ctx.tellNext(msg, checkMatches(msg) ? TbNodeConnectionType.TRUE : TbNodeConnectionType.FALSE); |
|
|
|