Package com.framed.cdss.reactors

Class SFComputationReactor

java.lang.Object

com.framed.core.Service

com.framed.arn.Reactor

com.framed.cdss.reactors.SFComputationReactor

public class SFComputationReactor
extends Reactor

Nested Class Summary

Nested classes/interfaces inherited from class com.framed.arn.Reactor

Reactor.Snapshot

Field Summary

Fields inherited from class com.framed.arn.Reactor

addressGroup, id, inputChannels, lastLogicalFireTs, outputChannels

Fields inherited from class com.framed.core.Service

ADDRESS_REGISTRY_SUFFIX, eventBus, formatter, logger

Constructor Summary

Constructors

Constructor	Description
SFComputationReactor(EventBus eventBus, String id, String spo2Channel, String fio2Channel, String outputChannel, boolean atomic)

Method Summary

Modifier and Type	Method	Description
void	reactionFunction(Map<String,Object> latestValues)	Called once per evaluation cycle when any rule is satisfied.

Methods inherited from class com.framed.arn.Reactor

getInputChannels, getOutputChannels, valueMatchesExpected

Methods inherited from class com.framed.core.Service

addressRegistry, announceAddress, stop

Methods inherited from class java.lang.Object

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

Constructor Details

SFComputationReactor

public SFComputationReactor(EventBus eventBus,
 String id,
 String spo2Channel,
 String fio2Channel,
 String outputChannel,
 boolean atomic)

Method Details

reactionFunction

public void reactionFunction(Map<String,Object> latestValues)

Description copied from class: Reactor

Called once per evaluation cycle when any rule is satisfied.

Specified by:

reactionFunction in class Reactor

Parameters:

latestValues - immutable snapshot of latest channel values and timestamps