D H L M O P S

D

destroy() - Method in class org.springframework.xd.rxjava.MultipleSubjectMessageHandler

destroy() - Method in class org.springframework.xd.rxjava.SubjectMessageHandler

H

handleMessageInternal(Message<?>) - Method in class org.springframework.xd.rxjava.MultipleSubjectMessageHandler

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

L

logger - Variable in class org.springframework.xd.rxjava.MultipleSubjectMessageHandler

logger - Variable in class org.springframework.xd.rxjava.SubjectMessageHandler

M

MultipleSubjectMessageHandler - Class in org.springframework.xd.rxjava

Adapts the item at a time delivery of a MessageHandler by delegating processing to an Observable based on a partitionExpression.

MultipleSubjectMessageHandler(Processor, String) - Constructor for class org.springframework.xd.rxjava.MultipleSubjectMessageHandler

O

org.springframework.xd.rxjava - package org.springframework.xd.rxjava

P

process(Observable<I>) - Method in interface org.springframework.xd.rxjava.Processor

Process a stream of messages and return an output stream.

Processor<I,O> - Interface in org.springframework.xd.rxjava

Contract for performing stream processing using RxJava within an XD processor module

S

setIntegrationEvaluationContext(EvaluationContext) - Method in class org.springframework.xd.rxjava.MultipleSubjectMessageHandler

SubjectMessageHandler - Class in org.springframework.xd.rxjava

Adapts the item at a time delivery of a MessageHandler by delegating processing to a Observable.

SubjectMessageHandler(Processor) - Constructor for class org.springframework.xd.rxjava.SubjectMessageHandler

D H L M O P S