org.springframework.cloud.function.stream

Class StreamConfiguration

java.lang.Object

org.springframework.cloud.function.stream.StreamConfiguration

@EnableConfigurationProperties(value=StreamConfigurationProperties.class)
 @ConditionalOnClass(value=org.springframework.cloud.stream.binder.Binder.class)
 @ConditionalOnBean(value=org.springframework.cloud.function.core.FunctionCatalog.class)
 @ConditionalOnProperty(name="spring.cloud.stream.enabled",
                       havingValue="true",
                       matchIfMissing=true)
 @EnableBinding(value=org.springframework.cloud.stream.messaging.Processor.class)
public class StreamConfiguration
extends Object

Author:

Mark Fisher, Marius Bogoevici

Constructor Summary

Constructors

Constructor and Description
StreamConfiguration()

Method Summary

Modifier and Type	Method and Description
StreamListeningFunctionInvoker	functionInvoker(FunctionCatalog registry, FunctionInspector functionInspector, org.springframework.cloud.stream.converter.CompositeMessageConverterFactory compositeMessageConverterFactory)
SupplierInvokingMessageProducer<Object>	supplierInvoker(FunctionCatalog registry)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamConfiguration

public StreamConfiguration()

Method Detail

supplierInvoker

@Bean
 @ConditionalOnProperty(name="spring.cloud.function.stream.supplier.enabled",
                       havingValue="true",
                       matchIfMissing=true)
public SupplierInvokingMessageProducer<Object> supplierInvoker(FunctionCatalog registry)

functionInvoker

@Bean
public StreamListeningFunctionInvoker functionInvoker(FunctionCatalog registry,
                                                            FunctionInspector functionInspector,
                                                            @Lazy
                                                            org.springframework.cloud.stream.converter.CompositeMessageConverterFactory compositeMessageConverterFactory)