DefaultRequestIdChecker

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

Constructors

Link copied to clipboard
constructor(idempotencyCheckerProvider: AggregateIdempotencyCheckerProvider, requestIdExistenceChecker: RequestIdExistenceChecker = NoopRequestIdExistenceChecker)

Functions

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

Returns true when the request ID can continue processing.