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 with a 30-second timeout.

abstract fun start()

Starts this component, initializing resources and beginning operations.

open fun stop()

Synchronously stops this resource with a 30-second timeout.

open fun stop(timeout: Duration)

Synchronously stops this resource within the specified timeout.

abstract fun stopGracefully(): Mono<Void>

Asynchronously closes this resource with graceful shutdown.