public interface ReactiveStreamsSubscribableChannel
void
subscribeTo(org.reactivestreams.Publisher<? extends org.springframework.messaging.Message<?>> publisher)
void subscribeTo(org.reactivestreams.Publisher<? extends org.springframework.messaging.Message<?>> publisher)