cn.geekcity.device.rule.service.ruleengine.impl

Class RuleEngineServiceImpl

java.lang.Object

cn.geekcity.device.rule.service.ruleengine.impl.RuleEngineServiceImpl

All Implemented Interfaces:

RuleEngineService, TimerListener, cn.geekcity.device.typedef.listener.EventListener, cn.geekcity.device.typedef.listener.PropertyListener

public class RuleEngineServiceImpl
extends java.lang.Object
implements RuleEngineService, cn.geekcity.device.typedef.listener.PropertyListener, cn.geekcity.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, cn.geekcity.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 cn.geekcity.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,
                             cn.geekcity.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 cn.geekcity.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 cn.geekcity.device.typedef.listener.PropertyListener

onTimerTriggered

public void onTimerTriggered(java.lang.String ruleId)

Specified by:

onTimerTriggered in interface TimerListener