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

Package-level declarations

Types

AbstractNotifierFilter

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

enum CommandStage : Enum<CommandStage>

CommandWaitEndpoint

interface CommandWaitEndpoint

CommandWaitNotifier

interface CommandWaitNotifier

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

CommandWaitNotifierSubscriber

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

EventHandledNotifierFilter

@Order(value = -2147483648)

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

LocalCommandWaitNotifier

class LocalCommandWaitNotifier(waitStrategyRegistrar: WaitStrategyRegistrar) : CommandWaitNotifier

MonoCommandWaitNotifier

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

ProcessedNotifierFilter

@Order(value = -2147483648)

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

ProjectedNotifierFilter

@Order(value = -2147483648)

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

SagaHandledNotifierFilter

@Order(value = -2147483648)

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

SimpleCommandWaitEndpoint

data class SimpleCommandWaitEndpoint(val endpoint: String) : CommandWaitEndpoint

SimpleWaitSignal

data class SimpleWaitSignal(val commandId: String, val stage: CommandStage, val function: FunctionInfoData, 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()) : WaitSignal

SimpleWaitStrategyRegistrar

object SimpleWaitStrategyRegistrar : WaitStrategyRegistrar

SnapshotNotifierFilter

@Order(value = -2147483648)

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

class WaitingFor(val stage: CommandStage, val contextName: String, val processorName: String = "") : WaitStrategy

interface WaitSignal : CommandId, ErrorInfo, CommandResultCapable, FunctionInfoCapable<FunctionInfoData>

interface WaitStrategy : ProcessorInfo

Command Wait Strategy

WaitStrategyInfo

data class WaitStrategyInfo(val commandWaitEndpoint: String, val stage: CommandStage, val contextName: String, val processorName: String) : ProcessorInfo

WaitStrategyRegistrar

interface WaitStrategyRegistrar

命令结果注册器.

Properties

COMMAND_WAIT_CONTEXT

const val COMMAND_WAIT_CONTEXT: String

COMMAND_WAIT_ENDPOINT

const val COMMAND_WAIT_ENDPOINT: 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

Functions

extractWaitStrategy

fun Header.extractWaitStrategy(): WaitStrategyInfo?

injectWaitStrategy

fun Header.injectWaitStrategy(commandWaitEndpoint: String, stage: CommandStage, context: String, processor: String = ""): Header

fun isLocalCommand(commandId: String): Boolean

thenNotifyAndForget

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