org.springframework.cloud.stream.function

Class IntegrationFlowFunctionSupport

java.lang.Object

org.springframework.cloud.stream.function.IntegrationFlowFunctionSupport

public class IntegrationFlowFunctionSupport
extends Object

Since:

2.1

Author:

Oleg Zhurakousky, David Turanski

Constructor Summary

Constructors

Constructor and Description
IntegrationFlowFunctionSupport(org.springframework.cloud.stream.function.FunctionCatalogWrapper functionCatalog, org.springframework.cloud.function.context.catalog.FunctionInspector functionInspector, CompositeMessageConverterFactory messageConverterFactory, StreamFunctionProperties functionProperties)

Method Summary

Modifier and Type	Method and Description
<I,O> boolean	andThenFunction(org.springframework.integration.dsl.IntegrationFlowBuilder flowBuilder, org.springframework.messaging.MessageChannel outputChannel) Add a Function bean to the end of an integration flow.
org.springframework.cloud.function.context.FunctionType	getCurrentFunctionType()
<O> org.springframework.integration.dsl.IntegrationFlowBuilder	integrationFlowForFunction(org.springframework.messaging.SubscribableChannel inputChannel, org.springframework.messaging.MessageChannel outputChannel)
<O> org.springframework.integration.dsl.IntegrationFlowBuilder	integrationFlowFromChannel(org.springframework.messaging.SubscribableChannel inputChannel)
org.springframework.integration.dsl.IntegrationFlowBuilder	integrationFlowFromNamedSupplier() Create an instance of the IntegrationFlowBuilder from a Supplier bean available in the context.
org.springframework.integration.dsl.IntegrationFlowBuilder	integrationFlowFromProvidedSupplier(Supplier<?> supplier) Create an instance of the IntegrationFlowBuilder from a provided Supplier.

Methods inherited from class java.lang.Object

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

Constructor Detail

IntegrationFlowFunctionSupport

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

Parameters:

functionCatalog -

functionInspector -

messageConverterFactory -

functionProperties -

Method Detail

getCurrentFunctionType

public org.springframework.cloud.function.context.FunctionType getCurrentFunctionType()

integrationFlowFromNamedSupplier

public org.springframework.integration.dsl.IntegrationFlowBuilder integrationFlowFromNamedSupplier()

Create an instance of the IntegrationFlowBuilder from a Supplier bean available in the context. The name of the bean must be provided via `spring.cloud.stream.function.definition` property.

Returns:

instance of IntegrationFlowBuilder

Throws:

IllegalStateException - if the named Supplier can not be located.

integrationFlowFromProvidedSupplier

public org.springframework.integration.dsl.IntegrationFlowBuilder integrationFlowFromProvidedSupplier(Supplier<?> supplier)

Create an instance of the IntegrationFlowBuilder from a provided Supplier.

Returns:

instance of IntegrationFlowBuilder

integrationFlowFromChannel

public <O> org.springframework.integration.dsl.IntegrationFlowBuilder integrationFlowFromChannel(org.springframework.messaging.SubscribableChannel inputChannel)

Parameters:

inputChannel -

Returns:

integrationFlowForFunction

public <O> org.springframework.integration.dsl.IntegrationFlowBuilder integrationFlowForFunction(org.springframework.messaging.SubscribableChannel inputChannel,
                                                                                                 org.springframework.messaging.MessageChannel outputChannel)

Parameters:

inputChannel -

outputChannel -

Returns:

andThenFunction

public <I,O> boolean andThenFunction(org.springframework.integration.dsl.IntegrationFlowBuilder flowBuilder,
                                     org.springframework.messaging.MessageChannel outputChannel)

Add a Function bean to the end of an integration flow. The name of the bean must be provided via `spring.cloud.stream.function.definition` property.

NOTE: If this method returns true, the integration flow is now represented as a Reactive Streams Publisher bean.

Parameters:

flowBuilder - instance of the IntegrationFlowBuilder representing the current state of the integration flow

outputChannel - channel where the output of a function will be sent

Returns:

true if Function was located and added and false if it wasn't.