cc.openxiot.gateway.device.rule.service.ruleagent.impl

Class RuleAgentServiceImpl

java.lang.Object

cc.openxiot.gateway.device.rule.service.ruleagent.impl.RuleAgentServiceImpl

All Implemented Interfaces:

RuleAgentService

public class RuleAgentServiceImpl
extends java.lang.Object
implements RuleAgentService

Constructor Summary

Constructors

Constructor and Description
RuleAgentServiceImpl()

Method Summary

Modifier and Type	Method and Description
void	addListener(cn.geekcity.xiot.spec.rule.listener.RuleExecutionListener listener) 添加：规则运行监听器
io.vertx.core.Future<java.lang.Void>	execute(java.lang.String ruleId) 执行场景（手动触发）
void	notifyRuleExecuted(java.lang.String ruleId, int status, java.lang.String description, java.util.List<cn.geekcity.xiot.spec.operation.AbstractOperation> operations) 通知：规则已执行完毕
void	notifyRuleTriggered(java.lang.String ruleId, cn.geekcity.xiot.spec.operation.AbstractOperation trigger) 通知：规则已触发
void	removeListener(cn.geekcity.xiot.spec.rule.listener.RuleExecutionListener listener) 删除：规则运行监听器
void	setExecutor(java.util.function.Function<java.lang.String,io.vertx.core.Future<java.lang.Void>> executor) 设置规则执行器
io.vertx.core.Future<java.lang.Void>	start() 启动
io.vertx.core.Future<java.lang.Void>	stop() 停止

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface cc.openxiot.gateway.device.rule.service.ruleagent.RuleAgentService

create

Constructor Detail

RuleAgentServiceImpl

public RuleAgentServiceImpl()

Method Detail

start

public io.vertx.core.Future<java.lang.Void> start()

Description copied from interface: RuleAgentService

启动

Specified by:

start in interface RuleAgentService

Returns:

future

stop

public io.vertx.core.Future<java.lang.Void> stop()

Description copied from interface: RuleAgentService

停止

Specified by:

stop in interface RuleAgentService

Returns:

future

addListener

public void addListener(cn.geekcity.xiot.spec.rule.listener.RuleExecutionListener listener)

Description copied from interface: RuleAgentService

添加：规则运行监听器

Specified by:

addListener in interface RuleAgentService

Parameters:

listener - 监听器

removeListener

public void removeListener(cn.geekcity.xiot.spec.rule.listener.RuleExecutionListener listener)

Description copied from interface: RuleAgentService

删除：规则运行监听器

Specified by:

removeListener in interface RuleAgentService

Parameters:

listener - 监听器

setExecutor

public void setExecutor(java.util.function.Function<java.lang.String,io.vertx.core.Future<java.lang.Void>> executor)

Description copied from interface: RuleAgentService

设置规则执行器

Specified by:

setExecutor in interface RuleAgentService

Parameters:

executor - 执行器

execute

public io.vertx.core.Future<java.lang.Void> execute(java.lang.String ruleId)

Description copied from interface: RuleAgentService

执行场景（手动触发）

Specified by:

execute in interface RuleAgentService

Parameters:

ruleId - 场景ID

Returns:

只要场景存在，就立即返回，执行的结果通过Listener通知上层。

notifyRuleTriggered

public void notifyRuleTriggered(java.lang.String ruleId,
                                cn.geekcity.xiot.spec.operation.AbstractOperation trigger)

Description copied from interface: RuleAgentService

通知：规则已触发

Specified by:

notifyRuleTriggered in interface RuleAgentService

Parameters:

ruleId - 规则ID

trigger - 触发条件

notifyRuleExecuted

public void notifyRuleExecuted(java.lang.String ruleId,
                               int status,
                               java.lang.String description,
                               java.util.List<cn.geekcity.xiot.spec.operation.AbstractOperation> operations)

Description copied from interface: RuleAgentService

通知：规则已执行完毕

Specified by:

notifyRuleExecuted in interface RuleAgentService

Parameters:

ruleId - 规则ID

status - 状态

description - 描述

operations - 操作集