process

open override fun process(exchange: ServerCommandExchange<*>): Mono<DomainEventStream>

Processes a command exchange by validating, executing, and persisting the results.

This method performs comprehensive command processing including:

  • Version conflict checking

  • Aggregate initialization validation

  • Ownership validation

  • Command execution with after-functions

  • Event sourcing to state

  • Event persistence

Return

A Mono containing the resulting domain event stream.

Parameters

exchange

The server command exchange to process.