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
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.