Skip navigation links
E G H I O P R S 

E

EnableRxJavaProcessor - Annotation Type in org.springframework.cloud.stream.annotation.rxjava
Annotation that identifies the class as RxJava processor module.

G

getPhase() - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler
 

H

handleMessageInternal(Message<?>) - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler
 

I

isAutoStartup() - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler
 
isRunning() - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler
 

O

org.springframework.cloud.stream.annotation.rxjava - package org.springframework.cloud.stream.annotation.rxjava
 

P

process(Observable<I>) - Method in interface org.springframework.cloud.stream.annotation.rxjava.RxJavaProcessor
 

R

RxJavaProcessor<I,O> - Interface in org.springframework.cloud.stream.annotation.rxjava
Marker interface that RxJava processor module uses to provide the implementation bean.
RxJavaProcessorConfiguration - Class in org.springframework.cloud.stream.annotation.rxjava
Configuration class for RxJava module support.
RxJavaProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.annotation.rxjava.RxJavaProcessorConfiguration
 

S

start() - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler
 
stop(Runnable) - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler
 
stop() - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler
 
subjectMessageHandler() - Method in class org.springframework.cloud.stream.annotation.rxjava.RxJavaProcessorConfiguration
 
SubjectMessageHandler - Class in org.springframework.cloud.stream.annotation.rxjava
Adapts the item at a time delivery of a MessageHandler by delegating processing to a Observable.
SubjectMessageHandler(RxJavaProcessor) - Constructor for class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler
 
E G H I O P R S 
Skip navigation links

Copyright © 2016 Pivotal Software, Inc.. All rights reserved.