org.springframework.cloud.stream.function

Class FunctionConfiguration

java.lang.Object

org.springframework.cloud.stream.function.FunctionConfiguration

@Configuration
 @ConditionalOnProperty(value="spring.cloud.stream.function.definition")
public class FunctionConfiguration
extends Object

Since:

2.1

Author:

Oleg Zhurakousky

Constructor Summary

Constructors

Constructor and Description
FunctionConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.cloud.stream.function.FunctionCatalogWrapper	functionCatalogWrapper(org.springframework.cloud.function.context.FunctionCatalog catalog)
IntegrationFlowFunctionSupport	functionSupport(org.springframework.cloud.stream.function.FunctionCatalogWrapper functionCatalog, org.springframework.cloud.function.context.catalog.FunctionInspector functionInspector, CompositeMessageConverterFactory messageConverterFactory, StreamFunctionProperties functionProperties)
org.springframework.integration.dsl.IntegrationFlow	integrationFlowCreator(IntegrationFlowFunctionSupport functionSupport) This configuration creates an instance of IntegrationFlow appropriate for binding declared using EnableBinding.

Methods inherited from class java.lang.Object

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

Constructor Detail

FunctionConfiguration

public FunctionConfiguration()

Method Detail

functionSupport

@Bean
public IntegrationFlowFunctionSupport functionSupport(org.springframework.cloud.stream.function.FunctionCatalogWrapper functionCatalog,
                                                            org.springframework.cloud.function.context.catalog.FunctionInspector functionInspector,
                                                            CompositeMessageConverterFactory messageConverterFactory,
                                                            StreamFunctionProperties functionProperties)

functionCatalogWrapper

@Bean
public org.springframework.cloud.stream.function.FunctionCatalogWrapper functionCatalogWrapper(org.springframework.cloud.function.context.FunctionCatalog catalog)

integrationFlowCreator

@ConditionalOnMissingBean
 @Bean
public org.springframework.integration.dsl.IntegrationFlow integrationFlowCreator(IntegrationFlowFunctionSupport functionSupport)

This configuration creates an instance of IntegrationFlow appropriate for binding declared using EnableBinding. At the moment only Source, Processor and Sink are supported.