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>>

Evicts aggregate state from the cache.

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

Link copied to clipboard
val cache: Cache<K, D>
Link copied to clipboard
open override val functionKind: FunctionKind
Link copied to clipboard

Functions

Link copied to clipboard
open override fun refresh(exchange: DomainEventExchange<Any>)