MessageDispatcher

Represents a message dispatcher that can run and dispatch messages.

This interface combines the capabilities of running a dispatch process, being closable for resource management, and having a name for identification.

Properties

abstract val name: String

open override fun close()

Closes this resource by performing a graceful shutdown.

abstract fun start()

Starts this component, initializing resources and beginning operations.

open fun stop()

Synchronously closes this resource with graceful shutdown.

open fun stop(timeout: Duration)

Synchronously closes this resource with graceful shutdown within a specified timeout.

abstract fun stopGracefully(): Mono<Void>

Asynchronously closes this resource with graceful shutdown.