6.0.6

wow-core/me.ahoo.wow.command.wait

Package-level declarations

Types

AbstractNotifierFilter

abstract class AbstractNotifierFilter<T : MessageExchange<*, M>, M : Message<*, *>, CommandId, NamedBoundedContext, AggregateIdCapable>(processingStage: CommandStage, commandWaitNotifier: CommandWaitNotifier) : ExchangeFilter<T>

enum CommandStage : Enum<CommandStage>

CommandStageCapable

interface CommandStageCapable

CommandWaitEndpoint

interface CommandWaitEndpoint

CommandWaitNotifier

interface CommandWaitNotifier

命令处理器完成处理后，将处理结果发往等待者

CommandWaitNotifierSubscriber

class CommandWaitNotifierSubscriber<E : MessageExchange<*, M>, M : Message<*, *>, CommandId, NamedBoundedContext, AggregateIdCapable>(commandWaitNotifier: CommandWaitNotifier, processingStage: CommandStage, waitStrategy: ExtractedWaitStrategy, messageExchange: E, actual: CoreSubscriber<in Void>) : BaseSubscriber<Void>

EventHandledNotifierFilter

class EventHandledNotifierFilter(commandWaitNotifier: CommandWaitNotifier) : AbstractNotifierFilter<DomainEventExchange<Any>, DomainEvent<*>>

ExtractedWaitStrategy

data class ExtractedWaitStrategy(val endpoint: String, val waitCommandId: String, val waitStrategy: WaitStrategy.Materialized) : CommandWaitEndpoint, WaitCommandIdCapable, MessagePropagator

LocalCommandWaitNotifier

class LocalCommandWaitNotifier(waitStrategyRegistrar: WaitStrategyRegistrar) : CommandWaitNotifier

MonoCommandWaitNotifier

class MonoCommandWaitNotifier<E : MessageExchange<*, M>, M : Message<*, *>, CommandId, NamedBoundedContext, AggregateIdCapable>(commandWaitNotifier: CommandWaitNotifier, processingStage: CommandStage, messageExchange: E, source: Mono<Void>) : Mono<Void>

NullableAggregateVersionCapable

interface NullableAggregateVersionCapable

ProcessedNotifierFilter

class ProcessedNotifierFilter(commandWaitNotifier: CommandWaitNotifier) : AbstractNotifierFilter<ServerCommandExchange<*>, CommandMessage<*>>

ProcessingStageShouldNotifyPredicate

fun interface ProcessingStageShouldNotifyPredicate

Functional interface for defining predicate logic to determine whether notification should be sent during processing stages.

ProjectedNotifierFilter

class ProjectedNotifierFilter(commandWaitNotifier: CommandWaitNotifier) : AbstractNotifierFilter<DomainEventExchange<Any>, DomainEvent<*>>

SagaHandledNotifierFilter

class SagaHandledNotifierFilter(commandWaitNotifier: CommandWaitNotifier) : AbstractNotifierFilter<DomainEventExchange<Any>, DomainEvent<*>>

SignalTimeCapable

interface SignalTimeCapable

SimpleCommandWaitEndpoint

data class SimpleCommandWaitEndpoint(val endpoint: String) : CommandWaitEndpoint

SimpleWaitSignal

data class SimpleWaitSignal(val id: String, val waitCommandId: String, val commandId: String, val aggregateId: AggregateId, val stage: CommandStage, val function: FunctionInfoData, val aggregateVersion: Int? = null, val isLastProjection: Boolean = false, val errorCode: String = ErrorCodes.SUCCEEDED, val errorMsg: String = ErrorCodes.SUCCEEDED_MESSAGE, val bindingErrors: List<BindingError> = emptyList(), val result: Map<String, Any> = emptyMap(), val commands: List<String> = listOf(), val signalTime: Long = System.currentTimeMillis()) : WaitSignal

SimpleWaitStrategyRegistrar

object SimpleWaitStrategyRegistrar : WaitStrategyRegistrar

SnapshotNotifierFilter

class SnapshotNotifierFilter(commandWaitNotifier: CommandWaitNotifier) : AbstractNotifierFilter<StateEventExchange<*>, StateEvent<*>>

WaitCommandIdCapable

interface WaitCommandIdCapable

abstract class WaitingFor : WaitStrategy

interface WaitSignal : Identifier, WaitCommandIdCapable, CommandId, AggregateIdCapable, NullableAggregateVersionCapable, ErrorInfo, SignalTimeCapable, CommandResultCapable, FunctionInfoCapable<FunctionInfoData>

WaitSignalShouldNotifyPredicate

fun interface WaitSignalShouldNotifyPredicate

Functional interface for defining predicate logic to determine whether notification should be sent for wait signals.

interface WaitStrategy : WaitCommandIdCapable, WaitStrategyPropagator, CompletedCapable

Command Wait Strategy

WaitStrategyPropagator

interface WaitStrategyPropagator

等待策略传播器接口

WaitStrategyRegistrar

interface WaitStrategyRegistrar

命令结果注册器.

Properties

COMMAND_WAIT_CONTEXT

const val COMMAND_WAIT_CONTEXT: String

COMMAND_WAIT_ENDPOINT

const val COMMAND_WAIT_ENDPOINT: String

COMMAND_WAIT_FUNCTION

const val COMMAND_WAIT_FUNCTION: String

COMMAND_WAIT_PREFIX

const val COMMAND_WAIT_PREFIX: String

COMMAND_WAIT_PROCESSOR

const val COMMAND_WAIT_PROCESSOR: String

COMMAND_WAIT_STAGE

const val COMMAND_WAIT_STAGE: String

WAIT_COMMAND_ID

const val WAIT_COMMAND_ID: String

Functions

extractCommandWaitEndpoint

fun Header.extractCommandWaitEndpoint(): String?

extractCommandWaitId

fun Header.extractCommandWaitId(): String?

extractWaitFunction

fun Header.extractWaitFunction(): NamedFunctionInfoData

extractWaitingStage

fun Header.extractWaitingStage(): CommandStage?

extractWaitStrategy

fun Header.extractWaitStrategy(): ExtractedWaitStrategy?

isLocalWaitStrategy

fun isLocalWaitStrategy(commandWaitId: String): Boolean

isWaitingForFunction

fun NamedFunctionInfo?.isWaitingForFunction(function: FunctionInfo): Boolean

notifyAndForget

fun CommandWaitNotifier.notifyAndForget(waiteStrategy: ExtractedWaitStrategy, waitSignal: WaitSignal)

propagateCommandWaitEndpoint

fun Header.propagateCommandWaitEndpoint(endpoint: String): Header

propagateWaitCommandId

fun Header.propagateWaitCommandId(commandId: String): Header

propagateWaitFunction

fun Header.propagateWaitFunction(function: NamedFunctionInfoData?): Header

propagateWaitingStage

fun Header.propagateWaitingStage(stage: CommandStage): Header

requireExtractCommandWaitEndpoint

fun Header.requireExtractCommandWaitEndpoint(): String

requireExtractWaitCommandId

fun Header.requireExtractWaitCommandId(): String

thenNotifyAndForget

fun <E : MessageExchange<*, M>, M : Message<*, *>, CommandId, NamedBoundedContext, AggregateIdCapable> Mono<Void>.thenNotifyAndForget(commandWaitNotifier: CommandWaitNotifier, processingStage: CommandStage, messageExchange: E): Mono<Void>