org.springframework.integration.dsl.kotlin / org.springframework.integration.dsl.IntegrationFlowDefinition

Extensions for org.springframework.integration.dsl.IntegrationFlowDefinition

convert

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

Extension for IntegrationFlowDefinition.convert providing a convert<MyType>() variant.

filterReified

fun <P> IntegrationFlowDefinition<*>.filterReified(function: (P) -> Boolean, configurer: (FilterEndpointSpec) -> Unit = {}): IntegrationFlowDefinition<*>

Extension for IntegrationFlowDefinition.filter providing a filter<MyTypeIn>() variant.

routeReified

fun <P, T> IntegrationFlowDefinition<*>.routeReified(function: (P) -> T, configurer: (RouterSpec<T, MethodInvokingRouter>) -> Unit = {}): IntegrationFlowDefinition<*>

Extension for IntegrationFlowDefinition.filter providing a filter<MyTypeIn>() variant.

split

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

Extension for IntegrationFlowDefinition.split providing a split<MyTypeIn>() variant.

transformReified

fun <P, T> IntegrationFlowDefinition<*>.transformReified(function: (P) -> T, configurer: (GenericEndpointSpec<MessageTransformingHandler>) -> Unit = {}): IntegrationFlowDefinition<*>

Extension for IntegrationFlowDefinition.transform providing a transform<MyTypeIn, MyTypeOut>() variant.