Package com.framed.cdss.reactors

Class DislocationClassificationReactor

java.lang.Object

com.framed.core.Service

com.framed.arn.Reactor

com.framed.cdss.reactors.DislocationClassificationReactor

public class DislocationClassificationReactor
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
DislocationClassificationReactor(EventBus eventBus, String id, String spo2TrendChannel, String etCO2LimitChannel, String sfLimitChannel, String outputChannel, boolean atomic)	Constructs an Reactor that subscribes to the given inputChannels, evaluates the provided firingRules, and optionally exposes outputChannels.

Method Summary

Modifier and Type	Method	Description
void	reactionFunction(Map<String,Object> latestSnapshot)	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

DislocationClassificationReactor

public DislocationClassificationReactor(EventBus eventBus,
 String id,
 String spo2TrendChannel,
 String etCO2LimitChannel,
 String sfLimitChannel,
 String outputChannel,
 boolean atomic)

Constructs an Reactor that subscribes to the given inputChannels, evaluates the provided firingRules, and optionally exposes outputChannels.

For each input channel, this actor:

1. Initializes its sequence counter and latest value holder;
2. Registers a message handler on the EventBus that updates state and evaluates rules.

During construction, rules are compiled to internal FiringRules and validated for channel existence.

Parameters:

eventBus - the event bus used to subscribe to input channels and receive messages; must not be null

id - the identifier of the specified Reactor. Commonly set in the config.

spo2TrendChannel - channel address for the SpO2 trend analysis

etCO2LimitChannel - channel address for the etCO2 limit analysis

sfLimitChannel - channel address for the sf Limit analysis

Throws:

NullPointerException - if any argument is null

IllegalArgumentException - if a rule is empty or references a channel not present in inputChannels, or contains an invalid token

Method Details

reactionFunction

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

Description copied from class: Reactor

Called once per evaluation cycle when any rule is satisfied.

Specified by:

reactionFunction in class Reactor

Parameters:

latestSnapshot - immutable snapshot of latest channel values and timestamps