ResendStateEventHandler

class ResendStateEventHandler(aggregateMetadata: AggregateMetadata<*, *>, eventStore: EventStore, stateEventCompensator: StateEventCompensator, batchExecutionPolicy: BatchExecutionPolicy)

Constructors

Link copied to clipboard
constructor(aggregateMetadata: AggregateMetadata<*, *>, eventStore: EventStore, stateEventCompensator: StateEventCompensator, batchExecutionPolicy: BatchExecutionPolicy)

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
fun resend(afterId: String, limit: Int): Flux<AggregateId>

Resends the state events of up to limit aggregates after afterId; emits each aggregate it resent.