StreamListener
with reactive types@Target(value=TYPE) @Retention(value=RUNTIME) @Documented @Inherited @EnableBinding(value=org.springframework.cloud.stream.messaging.Processor.class) @Import(value=RxJavaProcessorConfiguration.class) @Deprecated public @interface EnableRxJavaProcessor
EnableRxJavaProcessor
annotated is expected to provide a bean that implements RxJavaProcessor
.Copyright © 2017 Pivotal Software, Inc.. All rights reserved.