org.springframework.cloud.stream.annotation.rxjava

Class RxJavaProcessorConfiguration

java.lang.Object

org.springframework.cloud.stream.annotation.rxjava.RxJavaProcessorConfiguration

@Configuration
public class RxJavaProcessorConfiguration
extends Object

Configuration class for RxJava module support.

Author:

Ilayaperumal Gopinathan, Marius Bogoevici

Constructor Summary

Constructors

Constructor and Description
RxJavaProcessorConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.messaging.MessageHandler	subjectMessageHandler()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RxJavaProcessorConfiguration

public RxJavaProcessorConfiguration()

Method Detail

subjectMessageHandler

@ServiceActivator(inputChannel="input",
                  phase="0")
 @Bean
public org.springframework.messaging.MessageHandler subjectMessageHandler()