Package com.framed.cdss.actors

Class DislocationClassificationActor

java.lang.Object

com.framed.core.Service

com.framed.cdss.Actor

com.framed.cdss.actors.DislocationClassificationActor

public class DislocationClassificationActor
extends Actor

Field Summary

Fields inherited from class com.framed.cdss.Actor

id, inputChannels, outputChannels

Fields inherited from class com.framed.core.Service

eventBus, formatter, logger

Constructor Summary

Constructors

Constructor	Description
DislocationClassificationActor(EventBus eventBus, String id, String spo2TrendChannel, String etCO2LimitChannel, String sfLimitChannel, String outputChannel)	Constructs an Actor that subscribes to the given inputChannels, evaluates the provided firingRules, and optionally exposes outputChannels.

Method Summary

Modifier and Type	Method	Description
void	fireFunction(Map<String,Object> latestSnapshot)

Methods inherited from class com.framed.cdss.Actor

getInputChannels, getOutputChannels, valueMatchesExpected

Methods inherited from class com.framed.core.Service

stop

Methods inherited from class java.lang.Object

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

Constructor Details

DislocationClassificationActor

public DislocationClassificationActor(EventBus eventBus,
 String id,
 String spo2TrendChannel,
 String etCO2LimitChannel,
 String sfLimitChannel,
 String outputChannel)

Constructs an Actor 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 Actor. 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

fireFunction

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

Specified by:

fireFunction in class Actor

Parameters:

latestSnapshot - Unmodifiable snapshot of the latest value of ALL input channels (channel -> latest object).