spring-integration / org.springframework.integration.dsl / KotlinIntegrationFlowDefinition / split

split

inline fun <reified P> split(crossinline function: (P) -> Any): Unit
inline fun <reified P> split(crossinline function: (P) -> Any, crossinline configurer: KotlinSplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit): Unit

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

fun split(): Unit

Populate the DefaultMessageSplitter with provided options to the current integration flow position.

fun split(expression: String, endpointConfigurer: KotlinSplitterEndpointSpec<ExpressionEvaluatingSplitter>.() -> Unit = {}): Unit

Populate the ExpressionEvaluatingSplitter with provided SpEL expression.

fun split(service: Any, methodName: String? = null): Unit

Populate the MethodInvokingSplitter to evaluate the provided method of the service at runtime.

fun split(service: Any, methodName: String?, splitterConfigurer: KotlinSplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit): Unit
fun split(beanName: String, methodName: String?, splitterConfigurer: KotlinSplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit): Unit

Populate the MethodInvokingSplitter to evaluate the provided method of the bean at runtime. In addition accept options for the integration endpoint using KotlinSplitterEndpointSpec.

fun split(beanName: String, methodName: String? = null): Unit

Populate the MethodInvokingSplitter to evaluate the provided method of the bean at runtime.

fun split(messageProcessorSpec: MessageProcessorSpec<*>, splitterConfigurer: KotlinSplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit = {}): Unit

Populate the MethodInvokingSplitter to evaluate the MessageProcessor at runtime from provided MessageProcessorSpec. In addition accept options for the integration endpoint using KotlinSplitterEndpointSpec.

fun <S : AbstractMessageSplitter> split(splitterMessageHandlerSpec: MessageHandlerSpec<*, S>, splitterConfigurer: KotlinSplitterEndpointSpec<S>.() -> Unit = {}): Unit

Populate the provided AbstractMessageSplitter to the current integration flow position.

fun <S : AbstractMessageSplitter> split(splitter: S, splitterConfigurer: KotlinSplitterEndpointSpec<S>.() -> Unit = {}): Unit

Populate the provided AbstractMessageSplitter to the current integration flow position.