SetStateCacheRefresher
open class SetStateCacheRefresher<K, S : Any, D>(namedAggregate: NamedAggregate, stateToCacheDataConverter: StateToCacheDataConverter<ReadOnlyStateAggregate<S>, D>, val ttl: Long? = null, val amplitude: Long = 0, val cache: Cache<K, D>, val keyConvert: (StateDomainEventExchange<S, Any>) -> K = { exchange ->
@Suppress("UNCHECKED_CAST")
exchange.message.aggregateId.id as K
}) : StateCacheRefresher<S, D, StateDomainEventExchange<S, Any>> , CacheValueConfiguration
主动刷新缓存.
Constructors
Link copied to clipboard
constructor(namedAggregate: NamedAggregate, stateToCacheDataConverter: StateToCacheDataConverter<ReadOnlyStateAggregate<S>, D>, ttl: Long? = null, amplitude: Long = 0, cache: Cache<K, D>, keyConvert: (StateDomainEventExchange<S, 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
open fun <M : Message<*, Any>, NamedBoundedContext, NamedAggregate> supportMessage(message: M): Boolean