EvictStateCacheRefresher
open class EvictStateCacheRefresher<K, S : Any, D>(namedAggregate: NamedAggregate, val cache: Cache<K, D>, val keyConvert: (DomainEventExchange<Any>) -> K = { exchange ->
@Suppress("UNCHECKED_CAST")
exchange.message.aggregateId.id as K
}) : StateCacheRefresher<S, D, DomainEventExchange<Any>>
主动逐出缓存.
Constructors
Link copied to clipboard
constructor(namedAggregate: NamedAggregate, cache: Cache<K, D>, keyConvert: (DomainEventExchange<Any>) -> K = { exchange ->
@Suppress("UNCHECKED_CAST")
exchange.message.aggregateId.id as K
})
Properties
Functions
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open fun <M : Message<*, Any>, NamedBoundedContext, NamedAggregate> supportMessage(message: M): Boolean