EventProcessor

internal interface EventProcessor

Handles processing of incoming Events received via sync or WebSocket.

Each event is wrapped in an EventEnvelope, containing both the event and its delivery metadata. This interface allows disabling processing during testing or debug scenarios.

Events are dispatched to corresponding domain-specific receivers (e.g., ConversationEventReceiver) and marked as processed via EventRepository if processing is successful.

See also

Inheritors

Properties

Link copied to clipboard
abstract var disableEventProcessing: Boolean

When enabled events will be consumed but no event processing will occur.

Functions

Link copied to clipboard
abstract suspend fun processEvent(transactionContext: <Error class: unknown class>, eventEnvelope: EventEnvelope): <Error class: unknown class><<Error class: unknown class>, Unit>

Processes a single eventEnvelope using the provided transactionContext.