fun <T> IntegrationFlowDefinition<*>.convert(configurer: (GenericEndpointSpec<MessageTransformingHandler>) -> Unit = {}): IntegrationFlowDefinition<*>
Extension for IntegrationFlowDefinition.convert providing a |
|
fun <P> IntegrationFlowDefinition<*>.filterReified(function: (P) -> Boolean, configurer: (FilterEndpointSpec) -> Unit = {}): IntegrationFlowDefinition<*>
Extension for IntegrationFlowDefinition.filter providing a |
|
fun <P, T> IntegrationFlowDefinition<*>.routeReified(function: (P) -> T, configurer: (RouterSpec<T, MethodInvokingRouter>) -> Unit = {}): IntegrationFlowDefinition<*>
Extension for IntegrationFlowDefinition.filter providing a |
|
fun <P> IntegrationFlowDefinition<*>.split(function: (P) -> Any, configurer: (SplitterEndpointSpec<MethodInvokingSplitter>) -> Unit = {}): IntegrationFlowDefinition<*>
Extension for IntegrationFlowDefinition.split providing a |
|
fun <P, T> IntegrationFlowDefinition<*>.transformReified(function: (P) -> T, configurer: (GenericEndpointSpec<MessageTransformingHandler>) -> Unit = {}): IntegrationFlowDefinition<*>
Extension for IntegrationFlowDefinition.transform providing a |