Uses of Interface
com.framed.core.EventBus

Packages that use EventBus

Package	Description
com.framed.arn
com.framed.cdss.reactors
com.framed.communicator.driver.parser.medibus
com.framed.communicator.driver.parser.python
com.framed.communicator.driver.protocol.medibus
com.framed.communicator.driver.protocol.medibus.utils
com.framed.communicator.driver.protocol.replay
com.framed.communicator.io.parsed
com.framed.communicator.io.raw
com.framed.core
com.framed.core.local
com.framed.core.remote
com.framed.io.dispatch
com.framed.io.parser
com.framed.io.protocol
com.framed.io.writer
com.framed.orchestrator
com.framed.streamer.dispatcher

Uses of EventBus in com.framed.arn

Methods in com.framed.arn with parameters of type EventBus

Modifier and Type	Method	Description
static void	RuleUtils.publishResult(EventBus eventBus, Object value, String id, List<String> outputChannels, Instant timestamp)	Publishes a result envelope (timestamp, className, value, channelID) to each output channel and announces those channels so sinks can discover them.

Constructors in com.framed.arn with parameters of type EventBus

Modifier	Constructor	Description
protected	Reactor(EventBus eventBus, String id, List<Map<String,String>> firingRules, List<String> inputChannels, List<String> outputChannels)	Constructs a rule-based Actor.
protected	Reactor(EventBus eventBus, String id, List<Map<String,String>> firingRules, List<String> inputChannels, List<String> outputChannels, boolean atomic)	Constructs a rule-based reactor.

Uses of EventBus in com.framed.cdss.reactors

Constructors in com.framed.cdss.reactors with parameters of type EventBus

Modifier	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.
	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.
	InterpretationReactor(EventBus eventBus, String id, String rrMismatchChannel, String dislocationChannel, String spo2LimitChannel, String spo2TrendChannel, String etCO2LimitChannel, String hdArythChannel, String piLimitChannel, String hrLimitChannel, String sfLimitChannel, boolean atomic)
	LimitClassificationReactor(EventBus eventBus, String id, org.json.JSONArray firingRules, String inputChannel, org.json.JSONArray outputChannels, org.json.JSONArray limits, boolean atomic)	Constructs a LimitClassifier.
	RespiratoryRateEstimationReactor(EventBus eventBus, String id, String etco2Channel, org.json.JSONArray outputChannels, int windowSize, double riseSlopeMin, double fallSlopeMin, double minBreathIntervalSec, int historySeconds, boolean useEMA, double emaAlpha, boolean useHampel, int hampelWindow, double hampelK, boolean atomic)	Creates a respiratory rate estimator reactor that detects breaths from an EtCO₂ waveform using a robust slope-based algorithm with optional smoothing and outlier suppression.
	RRMismatchClassificationReactor(EventBus eventBus, String id, String rrEstimationChannel, String rrSettingsChannel, org.json.JSONArray outputChannels, int varLimit, boolean atomic)
	SFComputationReactor(EventBus eventBus, String id, String spo2Channel, String fio2Channel, String outputChannel, boolean atomic)
	TrendClassificationReactor(EventBus eventBus, String id, org.json.JSONArray firingRules, String inputChannel, org.json.JSONArray outputChannels, int windowSize, int persistWindows, int delta, String direction, boolean atomic)	Constructs a TrendClassifier that warns on decreasing trends using regression slope, with configurable persistence.

Uses of EventBus in com.framed.communicator.driver.parser.medibus

Constructors in com.framed.communicator.driver.parser.medibus with parameters of type EventBus

Modifier	Constructor	Description
	MedibusRealTimeParser(EventBus eventBus, int waveFormType, org.json.JSONArray devices)
	MedibusSlowParser(EventBus eventBus, org.json.JSONArray devices)

Uses of EventBus in com.framed.communicator.driver.parser.python

Constructors in com.framed.communicator.driver.parser.python with parameters of type EventBus

Modifier	Constructor	Description
	PythonParser(EventBus eventBus, org.json.JSONArray devices)

Uses of EventBus in com.framed.communicator.driver.protocol.medibus

Constructors in com.framed.communicator.driver.protocol.medibus with parameters of type EventBus

Modifier	Constructor	Description
	MedibusFramer(Consumer<byte[]> frameHandler, EventBus eventBus, String deviceID)
	MedibusProtocol(String id, String portName, int baudRate, int dataBits, int stopBits, int waveFormType, boolean realTime, boolean slowData, String multiplier, EventBus eventBus)

Uses of EventBus in com.framed.communicator.driver.protocol.medibus.utils

Methods in com.framed.communicator.driver.protocol.medibus.utils with parameters of type EventBus

Modifier and Type	Method	Description
static void	ParsingUtils.readRealtimeConfigResponse(byte[] packetData, EventBus eventBus, String id)

Uses of EventBus in com.framed.communicator.driver.protocol.replay

Constructors in com.framed.communicator.driver.protocol.replay with parameters of type EventBus

Modifier	Constructor	Description
	ReplayProtocol(String id, EventBus eventBus, String filePath, org.json.JSONArray devices)

Uses of EventBus in com.framed.communicator.io.parsed

Constructors in com.framed.communicator.io.parsed with parameters of type EventBus

Modifier	Constructor	Description
	MedibusParsedWriter(String path, EventBus eventBus, org.json.JSONArray devices)

Uses of EventBus in com.framed.communicator.io.raw

Constructors in com.framed.communicator.io.raw with parameters of type EventBus

Modifier	Constructor	Description
	RawByteWriter(String path, EventBus eventBus, org.json.JSONArray devices)

Uses of EventBus in com.framed.core

Fields in com.framed.core declared as EventBus

Modifier and Type	Field	Description
protected EventBus	Service.eventBus	The event bus used for communication between components.

Constructors in com.framed.core with parameters of type EventBus

Modifier	Constructor	Description
protected	Service(EventBus eventBus)	Creates a new service instance with the specified event bus.

Uses of EventBus in com.framed.core.local

Classes in com.framed.core.local that implement EventBus

Modifier and Type	Class	Description
class	LocalEventBus	A local implementation of the EventBus interface for message-based communication between components within the same JVM.

Uses of EventBus in com.framed.core.remote

Classes in com.framed.core.remote that implement EventBus

Modifier and Type	Class	Description
class	SocketEventBus	A distributed EventBus implementation backed by a Transport for remote communication.

Uses of EventBus in com.framed.io.dispatch

Constructors in com.framed.io.dispatch with parameters of type EventBus

Modifier	Constructor	Description
protected	Dispatcher(EventBus eventBus, org.json.JSONArray devices)	Creates a dispatcher bound to the given event bus and set of devices.

Uses of EventBus in com.framed.io.parser

Constructors in com.framed.io.parser with parameters of type EventBus

Modifier	Constructor	Description
protected	Parser(EventBus eventBus)	Creates a new parser bound to the given event bus.

Uses of EventBus in com.framed.io.protocol

Constructors in com.framed.io.protocol with parameters of type EventBus

Modifier	Constructor	Description
	Protocol(String id, EventBus eventBus)	Creates a new Protocol instance.

Uses of EventBus in com.framed.io.writer

Constructors in com.framed.io.writer with parameters of type EventBus

Modifier	Constructor	Description
protected	Writer(String path, EventBus eventBus)	Creates a new Writer instance.

Uses of EventBus in com.framed.orchestrator

Methods in com.framed.orchestrator with parameters of type EventBus

Modifier and Type	Method	Description
static Service	Factory.instantiate(org.json.JSONObject config, EventBus eventBus)	Instantiates a Service implementation based on the provided configuration and event bus.

Constructors in com.framed.orchestrator with parameters of type EventBus

Modifier	Constructor	Description
	Manager(org.json.JSONObject config, EventBus eventBus)	Creates a new Manager with the given configuration and event bus.

Uses of EventBus in com.framed.streamer.dispatcher

Constructors in com.framed.streamer.dispatcher with parameters of type EventBus

Modifier	Constructor	Description
	FfillDispatcher(EventBus eventBus, org.json.JSONArray devices, Long frequencyMillis)
	InfluxDispatcher(EventBus eventBus, org.json.JSONArray devices, String url, String token, String org, String bucket)
	JsonlDispatcher(EventBus eventBus, org.json.JSONArray devices, String path, String fileName)