Package com.framed.cdss.reactors

Class HemodynamicRhythmClassificationReactor

java.lang.Object

com.framed.core.Service

com.framed.arn.Reactor

com.framed.cdss.reactors.HemodynamicRhythmClassificationReactor

public class HemodynamicRhythmClassificationReactor
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
HemodynamicRhythmClassificationReactor(EventBus eventBus, String id, String etCO2TrendChannel, String hrLimitChannel, 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

HemodynamicRhythmClassificationReactor

public HemodynamicRhythmClassificationReactor(EventBus eventBus,
 String id,
 String etCO2TrendChannel,
 String hrLimitChannel,
 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.

etCO2TrendChannel - the channel on which the etCO2 trend warning is published

hrLimitChannel - the channel on which the Heartrate limit warning is published

outputChannel - the channel on which to publish the arrhythmia warning

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