existsRequestId

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

Checks whether the request ID already exists for the specified aggregate.

Implementations may override this method with an indexed lookup. The default implementation keeps source compatibility for custom event stores by scanning the aggregate event stream.

Return

a Mono emitting true if the request ID already exists for this aggregate

Parameters

aggregateId

the aggregate ID to check

requestId

the request identifier to check