6.0.6

wow-test/me.ahoo.wow.test.saga.stateless

Package-level declarations

Types

CommandIterator

class CommandIterator(val delegate: Iterator<CommandMessage<*>>) : Iterator<CommandMessage<*>> , Decorator<Iterator<CommandMessage<*>>>

data class ExpectedResult<T : Any>(val exchange: DomainEventExchange<*>, val processor: T, val commandStream: CommandStream?, val error: Throwable? = null) : StatelessSagaExpecter<T, ExpectedResult<T>>

interface ExpectStage<T : Any> : StatelessSagaExpecter<T, ExpectStage<T>>

GivenReadOnlyStateAggregate

class GivenReadOnlyStateAggregate<S : Any>(val aggregateId: AggregateId, val state: S, val version: Int, val ownerId: String, val deleted: Boolean, val eventId: String, val firstOperator: String, val operator: String, val firstEventTime: Long, val eventTime: Long) : ReadOnlyStateAggregate<S>

StatelessSagaExpecter

interface StatelessSagaExpecter<T : Any, SE : StatelessSagaExpecter<T, SE>>

interface WhenStage<T : Any> : InjectServiceCapable<WhenStage<T>>

Stateless Saga: