public interface ReactiveSubscribableChannel
void
subscribeTo(org.reactivestreams.Publisher<Message<?>> publisher)
void subscribeTo(org.reactivestreams.Publisher<Message<?>> publisher)