org.springframework.integration.dsl / KotlinIntegrationFlowDefinition

KotlinIntegrationFlowDefinition

class KotlinIntegrationFlowDefinition : BaseIntegrationFlowDefinition<KotlinIntegrationFlowDefinition>

A BaseIntegrationFlowDefinition extension for Kotlin-specif inline functions with reified generic types.

Constructors

<init>

KotlinIntegrationFlowDefinition(adaptee: IntegrationFlowDefinition<*>)

A BaseIntegrationFlowDefinition extension for Kotlin-specif inline functions with reified generic types.

Functions

addComponent

fun addComponent(component: Any): KotlinIntegrationFlowDefinition
fun addComponent(component: Any, beanName: String?): KotlinIntegrationFlowDefinition

Delegate a provided component into an adaptee set of components.

addComponents

fun addComponents(components: Map<Any, String>?): KotlinIntegrationFlowDefinition

Delegate provided components into an adaptee set of components.

convert

fun <T> convert(configurer: (GenericEndpointSpec<MessageTransformingHandler>) -> Unit = {}): KotlinIntegrationFlowDefinition

Inline function for IntegrationFlowDefinition.convert providing a convert<MyType>() variant with reified generic type.

currentComponent

fun currentComponent(component: Any?): KotlinIntegrationFlowDefinition

Delegate a provided component into an adaptee current component.

currentMessageChannel

fun currentMessageChannel(currentMessageChannel: MessageChannel?): KotlinIntegrationFlowDefinition

Set a provided MessageChannel as a current in the adaptee.

filter

fun <P> filter(function: (P) -> Boolean, configurer: (FilterEndpointSpec) -> Unit = {}): KotlinIntegrationFlowDefinition

Inline function for IntegrationFlowDefinition.filter providing a filter<MyTypeIn>() variant with reified generic type.

getCurrentComponent

fun getCurrentComponent(): Any?

Get a current component from adaptee.

getCurrentMessageChannel

fun getCurrentMessageChannel(): MessageChannel?

Get a current MessageChannel from the adaptee.

getIntegrationComponents

fun getIntegrationComponents(): Map<Any, String>

Get a Map of components from adaptee.

isImplicitChannel

fun isImplicitChannel(): Boolean

Get an implicit channel flag from the adaptee.

route

fun <P, T> route(function: (P) -> T, configurer: (RouterSpec<T, MethodInvokingRouter>) -> Unit = {}): KotlinIntegrationFlowDefinition

Inline function for IntegrationFlowDefinition.filter providing a filter<MyTypeIn>() variant with reified generic type.

setImplicitChannel

fun setImplicitChannel(implicitChannel: Boolean): Unit

Set a flag for an implicit channel on the adaptee.

split

fun <P> split(function: (P) -> Any, configurer: (SplitterEndpointSpec<MethodInvokingSplitter>) -> Unit = {}): KotlinIntegrationFlowDefinition

Inline function for IntegrationFlowDefinition.split providing a split<MyTypeIn>() variant with reified generic type.

transform

fun <P, T> transform(function: (P) -> T, configurer: (GenericEndpointSpec<MessageTransformingHandler>) -> Unit = {}): KotlinIntegrationFlowDefinition

Inline function for IntegrationFlowDefinition.transform providing a transform<MyTypeIn, MyTypeOut>() variant with reified generic type.