agents-features-common/ai.koog.agents.local.features.common.message/FeatureMessageProcessor

FeatureMessageProcessor

abstract class FeatureMessageProcessor : Closeable(source)

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

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
abstract suspend fun close()
Link copied to clipboard
open suspend fun initialize()

Initializes the feature output stream provider to ensure it is ready for use.

Link copied to clipboard
abstract suspend fun processMessage(message: FeatureMessage)

Handles an incoming feature message or event for processing.