messageFlux

abstract val messageFlux: Flux<T>