reactive

open override fun reactive(): S

fun reactive(reactiveCustomizer: (Flux<Message<*>>) -> Publisher<Message<*>>)