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

Class RuleEngineServiceImpl

java.lang.Object

cc.openxiot.gateway.device.rule.service.ruleengine.impl.RuleEngineServiceImpl

All Implemented Interfaces:

RuleEngineService, TimerListener, cc.openxiot.gateway.device.typedef.listener.EventListener, cc.openxiot.gateway.device.typedef.listener.PropertyListener

public class RuleEngineServiceImpl
extends java.lang.Object
implements RuleEngineService, cc.openxiot.gateway.device.typedef.listener.PropertyListener, cc.openxiot.gateway.device.typedef.listener.EventListener, TimerListener

Constructor Summary

Constructors

Constructor and Description
RuleEngineServiceImpl(io.vertx.core.Vertx vertx, java.util.function.Function<cn.geekcity.xiot.spec.device.Device,io.vertx.core.Future<cn.geekcity.xiot.spec.image.DeviceImage>> getImage, cn.geekcity.xiot.spec.time.service.DayService day, RuleService rule, RuleAgentService agent, cc.openxiot.gateway.device.typedef.manager.DeviceManager manager)

Method Summary

Modifier and Type	Method and Description
void	onEventOccurred(java.lang.String traceId, cn.geekcity.xiot.spec.where.Where where, cn.geekcity.xiot.spec.operation.EventOperation event)
void	onPropertyChanged(java.lang.String traceId, cn.geekcity.xiot.spec.where.Where where, cn.geekcity.xiot.spec.operation.PropertyOperation property)
void	onTimerTriggered(java.lang.String ruleId)
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.ruleengine.RuleEngineService

create

Constructor Detail

RuleEngineServiceImpl

public RuleEngineServiceImpl(io.vertx.core.Vertx vertx,
                             java.util.function.Function<cn.geekcity.xiot.spec.device.Device,io.vertx.core.Future<cn.geekcity.xiot.spec.image.DeviceImage>> getImage,
                             cn.geekcity.xiot.spec.time.service.DayService day,
                             RuleService rule,
                             RuleAgentService agent,
                             cc.openxiot.gateway.device.typedef.manager.DeviceManager manager)

Method Detail

start

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

Description copied from interface: RuleEngineService

启动

Specified by:

start in interface RuleEngineService

Returns:

future

stop

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

Description copied from interface: RuleEngineService

停止

Specified by:

stop in interface RuleEngineService

Returns:

future

onEventOccurred

public void onEventOccurred(java.lang.String traceId,
                            cn.geekcity.xiot.spec.where.Where where,
                            cn.geekcity.xiot.spec.operation.EventOperation event)

Specified by:

onEventOccurred in interface cc.openxiot.gateway.device.typedef.listener.EventListener

onPropertyChanged

public void onPropertyChanged(java.lang.String traceId,
                              cn.geekcity.xiot.spec.where.Where where,
                              cn.geekcity.xiot.spec.operation.PropertyOperation property)

Specified by:

onPropertyChanged in interface cc.openxiot.gateway.device.typedef.listener.PropertyListener

onTimerTriggered

public void onTimerTriggered(java.lang.String ruleId)

Specified by:

onTimerTriggered in interface TimerListener