FeatureMessageProcessor

Represents a provider responsible for handling outbound feature messages or events.

Feature processors are used to encapsulate feature-related logic and provide a common interface for handling feature messages and events, such as

• Node started

• Node finished

• Strategy started, etc.

Implementations of this interface are designed to process feature messages, which are encapsulated in the FeatureMessage type and presented as a model for an event to be sent to a target stream. These messages carry information about various events or updates related to features in the system.

Inheritors

Abstract class responsible for processing feature messages within the system.

The FeatureMessageProcessor provides functionality for filtering and handling incoming feature messages. Classes inheriting from this abstract class are expected to implement the necessary logic for processing messages.

This class provides Java-friendly APIs for initializing and processing messages synchronously, in addition to its coroutine-based methods for use in Kotlin.

Java subclasses should override handleMessage and handleClose instead of the suspend processMessage and close methods to avoid dealing with Kotlin coroutine internals.

Abstract class responsible for processing feature messages or events within the system.

The FeatureMessageProcessor serves as a foundational interface for implementing processors that handle various feature-related messages. These messages, represented by the FeatureMessage type, encapsulate relevant information about events or updates in the system.

This class provides mechanisms to filter incoming messages, manage processing states, and ensure proper handling through a defined workflow.