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
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.