wow-core/me.ahoo.wow.command/DefaultRequestIdChecker

DefaultRequestIdChecker

class DefaultRequestIdChecker(idempotencyCheckerProvider: AggregateIdempotencyCheckerProvider, requestIdExistenceChecker: RequestIdExistenceChecker = NoopRequestIdExistenceChecker) : RequestIdChecker

Constructors

constructor(idempotencyCheckerProvider: AggregateIdempotencyCheckerProvider, requestIdExistenceChecker: RequestIdExistenceChecker = NoopRequestIdExistenceChecker)

Functions

check

open override fun check(aggregateId: AggregateId, requestId: String): Mono<Boolean>

Returns true when the request ID can continue processing.

release

open override fun release(aggregateId: AggregateId, requestId: String)

Gives back the reservation a passing check made when the command could not be sent, so that a retry with the same request ID is not taken for a duplicate. The default does nothing.