AbstractWaitingFor

Constructors

Link copied to clipboard
constructor()

Properties

Link copied to clipboard
abstract val contextName: String
Link copied to clipboard
abstract val processorName: String
Link copied to clipboard
abstract val stage: CommandStage

Functions

Link copied to clipboard
open override fun error(throwable: Throwable)
Link copied to clipboard
fun NamedBoundedContext.getContextAlias(boundedContext: BoundedContext? = MetadataSearcher.metadata.contexts[contextName]): String
Link copied to clipboard
Link copied to clipboard
abstract fun next(signal: WaitSignal)

由下游(CommandBus or Aggregate or Projector)发送处理结果信号.

Link copied to clipboard
open override fun waiting(): Mono<WaitSignal>