public class IntegrationFlowFunctionSupport extends Object
Modifier and Type | Method and Description |
---|---|
<I,O> boolean |
andThenFunction(org.springframework.integration.dsl.IntegrationFlowBuilder flowBuilder,
org.springframework.messaging.MessageChannel outputChannel,
String functionName)
Add a
Function bean to the end of an integration flow. |
<I,O> boolean |
andThenFunction(org.reactivestreams.Publisher<?> publisher,
org.springframework.messaging.MessageChannel outputChannel,
String functionName) |
<T> boolean |
containsFunction(Class<T> typeOfFunction)
Determines if function specified via 'spring.cloud.stream.function.definition'
property can be located in
FunctionCatalog |
<T> boolean |
containsFunction(Class<T> typeOfFunction,
String functionName)
Determines if function specified via 'spring.cloud.stream.function.definition'
property can be located in
FunctionCatalog |
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 . |
public <T> boolean containsFunction(Class<T> typeOfFunction)
FunctionCatalog
typeOfFunction
- must be Supplier, Function or Consumerpublic <T> boolean containsFunction(Class<T> typeOfFunction, String functionName)
FunctionCatalog
typeOfFunction
- must be Supplier, Function or ConsumerfunctionName
- the function name to checkpublic org.springframework.cloud.function.context.FunctionType getCurrentFunctionType()
public org.springframework.integration.dsl.IntegrationFlowBuilder integrationFlowFromNamedSupplier()
IntegrationFlowBuilder
from a Supplier
bean available in the context.
The name of the bean must be provided via `spring.cloud.stream.function.definition` property.IntegrationFlowBuilder
IllegalStateException
- if the named Supplier can not be located.public org.springframework.integration.dsl.IntegrationFlowBuilder integrationFlowFromProvidedSupplier(Supplier<?> supplier)
IntegrationFlowBuilder
from a provided Supplier
.IntegrationFlowBuilder
public <O> org.springframework.integration.dsl.IntegrationFlowBuilder integrationFlowFromChannel(org.springframework.messaging.SubscribableChannel inputChannel)
inputChannel
- public <O> org.springframework.integration.dsl.IntegrationFlowBuilder integrationFlowForFunction(org.springframework.messaging.SubscribableChannel inputChannel, org.springframework.messaging.MessageChannel outputChannel)
public <I,O> boolean andThenFunction(org.springframework.integration.dsl.IntegrationFlowBuilder flowBuilder, org.springframework.messaging.MessageChannel outputChannel, String functionName)
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.
flowBuilder
- instance of the IntegrationFlowBuilder
representing
the current state of the integration flowoutputChannel
- channel where the output of a function will be sentfunctionName
- the function name to useFunction
was located and added and false if it wasn't.public <I,O> boolean andThenFunction(org.reactivestreams.Publisher<?> publisher, org.springframework.messaging.MessageChannel outputChannel, String functionName)
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.