wow-cocache/me.ahoo.wow.cache.refresh/StateCacheRefresher

StateCacheRefresher

abstract class StateCacheRefresher<S : Any, D, M : DomainEventExchange<*>>(val namedAggregate: NamedAggregate) : NamedAggregateDecorator, MessageFunction<StateCacheRefresher<S, D, M>, M, Mono<Void>>

Proactively refreshes aggregate state caches.

Inheritors

EvictStateCacheRefresher

SetStateCacheRefresher

Constructors

StateCacheRefresher

constructor(namedAggregate: NamedAggregate)

Types

object Companion

Properties

open override val aggregateName: String

open override val contextName: String

abstract val functionKind: FunctionKind

open override val name: String

override val namedAggregate: NamedAggregate

open override val processor: StateCacheRefresher<S, D, M>

open override val processorName: String

open override val qualifiedName: String

supportedTopics

override val supportedTopics: Set<NamedAggregate>

open override val supportedType: Class<*>

Functions

open override fun <A : Annotation> getAnnotation(annotationClass: Class<A>): A?

open fun handle(exchange: M): Mono<Void>

open operator override fun invoke(exchange: M): Mono<Void>

open fun isEmpty(): Boolean

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

open fun isSameFunction(functionInfo: FunctionInfo): Boolean

abstract fun refresh(exchange: M)

open fun <M : Message<*, Any>, NamedBoundedContext, NamedAggregate> supportMessage(message: M): Boolean