class KotlinIntegrationFlowDefinition : BaseIntegrationFlowDefinition<KotlinIntegrationFlowDefinition>
A BaseIntegrationFlowDefinition extension for Kotlin-specif inline functions with reified generic types.
KotlinIntegrationFlowDefinition(adaptee: IntegrationFlowDefinition<*>)
A BaseIntegrationFlowDefinition extension for Kotlin-specif inline functions with reified generic types. |
fun addComponent(component: Any): KotlinIntegrationFlowDefinitionfun addComponent(component: Any, beanName: String?): KotlinIntegrationFlowDefinition
Delegate a provided component into an |
|
fun addComponents(components: Map<Any, String>?): KotlinIntegrationFlowDefinition
Delegate provided components into an |
|
fun <T> convert(configurer: (GenericEndpointSpec<MessageTransformingHandler>) -> Unit = {}): KotlinIntegrationFlowDefinition
Inline function for IntegrationFlowDefinition.convert providing a |
|
fun currentComponent(component: Any?): KotlinIntegrationFlowDefinition
Delegate a provided component into an |
|
fun currentMessageChannel(currentMessageChannel: MessageChannel?): KotlinIntegrationFlowDefinition
Set a provided MessageChannel as a current in the |
|
fun <P> filter(function: (P) -> Boolean, configurer: (FilterEndpointSpec) -> Unit = {}): KotlinIntegrationFlowDefinition
Inline function for IntegrationFlowDefinition.filter providing a |
|
fun getCurrentComponent(): Any?
Get a current component from |
|
fun getCurrentMessageChannel(): MessageChannel?
Get a current MessageChannel from the |
|
fun getIntegrationComponents(): Map<Any, String>
Get a Map of components from |
|
fun isImplicitChannel(): Boolean
Get an implicit channel flag from the |
|
fun <P, T> route(function: (P) -> T, configurer: (RouterSpec<T, MethodInvokingRouter>) -> Unit = {}): KotlinIntegrationFlowDefinition
Inline function for IntegrationFlowDefinition.filter providing a |
|
fun setImplicitChannel(implicitChannel: Boolean): Unit
Set a flag for an implicit channel on the |
|
fun <P> split(function: (P) -> Any, configurer: (SplitterEndpointSpec<MethodInvokingSplitter>) -> Unit = {}): KotlinIntegrationFlowDefinition
Inline function for IntegrationFlowDefinition.split providing a |
|
fun <P, T> transform(function: (P) -> T, configurer: (GenericEndpointSpec<MessageTransformingHandler>) -> Unit = {}): KotlinIntegrationFlowDefinition
Inline function for IntegrationFlowDefinition.transform providing a |