org.springframework.cloud.function.stream

Class StreamListeningFunctionInvoker

java.lang.Object

org.springframework.cloud.function.stream.StreamListeningFunctionInvoker

All Implemented Interfaces:

org.springframework.beans.factory.SmartInitializingSingleton

public class StreamListeningFunctionInvoker
extends Object
implements org.springframework.beans.factory.SmartInitializingSingleton

Author:

Mark Fisher, Marius Bogoevici

Constructor Summary

Constructors

Constructor and Description
StreamListeningFunctionInvoker(FunctionCatalog functionCatalog, FunctionInspector functionInspector, org.springframework.cloud.stream.converter.CompositeMessageConverterFactory converterFactory, String defaultRoute)

Method Summary

Modifier and Type	Method and Description
void	afterSingletonsInstantiated()
reactor.core.publisher.Mono<Void>	handle(reactor.core.publisher.Flux<org.springframework.messaging.Message<?>> input, org.springframework.cloud.stream.reactive.FluxSender output)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamListeningFunctionInvoker

public StreamListeningFunctionInvoker(FunctionCatalog functionCatalog,
                                      FunctionInspector functionInspector,
                                      org.springframework.cloud.stream.converter.CompositeMessageConverterFactory converterFactory,
                                      String defaultRoute)

Method Detail

afterSingletonsInstantiated

public void afterSingletonsInstantiated()

Specified by:

afterSingletonsInstantiated in interface org.springframework.beans.factory.SmartInitializingSingleton

handle

@StreamListener
public reactor.core.publisher.Mono<Void> handle(@Input(value="input")
                                                                reactor.core.publisher.Flux<org.springframework.messaging.Message<?>> input,
                                                                @Output(value="output")
                                                                org.springframework.cloud.stream.reactive.FluxSender output)