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