Module Contents
alltypes
Module Contents
class KotlinIntegrationFlowDefinition : BaseIntegrationFlowDefinition<KotlinIntegrationFlowDefinition>
Module Contents
KotlinIntegrationFlowDefinition(adaptee: IntegrationFlowDefinition<*>)
protected fun addComponent(component: Any): KotlinIntegrationFlowDefinition
protected fun addComponent(component: Any, beanName: String?): KotlinIntegrationFlowDefinition
protected fun addComponents(components: Map<Any, String>?): KotlinIntegrationFlowDefinition
inline fun <reified T> convert(crossinline configurer: (GenericEndpointSpec<MessageTransformingHandler>) -> Unit = {}): KotlinIntegrationFlowDefinition
protected fun currentComponent(component: Any?): KotlinIntegrationFlowDefinition
protected fun currentMessageChannel(currentMessageChannel: MessageChannel?): KotlinIntegrationFlowDefinition
inline fun <reified P> filter(crossinline function: (P) -> Boolean, crossinline configurer: (FilterEndpointSpec) -> Unit = {}): KotlinIntegrationFlowDefinition
protected fun getCurrentComponent(): Any?
protected fun getCurrentMessageChannel(): MessageChannel?
protected fun getIntegrationComponents(): Map<Any, String>
protected fun isImplicitChannel(): Boolean
inline fun <reified P, T> route(crossinline function: (P) -> T, crossinline configurer: (RouterSpec<T, MethodInvokingRouter>) -> Unit = {}): KotlinIntegrationFlowDefinition
protected fun setImplicitChannel(implicitChannel: Boolean): Unit
inline fun <reified P> split(crossinline function: (P) -> Any, crossinline configurer: (SplitterEndpointSpec<MethodInvokingSplitter>) -> Unit = {}): KotlinIntegrationFlowDefinition
inline fun <reified P, T> transform(crossinline function: (P) -> T, crossinline configurer: (GenericEndpointSpec<MessageTransformingHandler>) -> Unit = {}): KotlinIntegrationFlowDefinition
package org.springframework.integration.dsl
Module Contents
fun integrationFlow(flow: KotlinIntegrationFlowDefinition.() -> Unit): IntegrationFlow
inline fun <reified T> integrationFlow(crossinline gateway: (GatewayProxySpec) -> Unit = {}, flow: KotlinIntegrationFlowDefinition.() -> Unit): IntegrationFlow
fun integrationFlow(channelName: String, fixedSubscriber: Boolean = false, flow: KotlinIntegrationFlowDefinition.() -> Unit): IntegrationFlow
fun integrationFlow(channel: MessageChannel, flow: KotlinIntegrationFlowDefinition.() -> Unit): IntegrationFlow
fun integrationFlow(messageSource: MessageSource<*>, options: (SourcePollingChannelAdapterSpec) -> Unit = {}, flow: KotlinIntegrationFlowDefinition.() -> Unit): IntegrationFlow
fun integrationFlow(messageSource: MessageSourceSpec<*, out MessageSource<*>>, options: (SourcePollingChannelAdapterSpec) -> Unit = {}, flow: KotlinIntegrationFlowDefinition.() -> Unit): IntegrationFlow
fun integrationFlow(source: () -> Any, options: (SourcePollingChannelAdapterSpec) -> Unit = {}, flow: KotlinIntegrationFlowDefinition.() -> Unit): IntegrationFlow
fun integrationFlow(publisher: Publisher<out Message<*>>, flow: KotlinIntegrationFlowDefinition.() -> Unit): IntegrationFlow
fun integrationFlow(gateway: MessagingGatewaySupport, flow: KotlinIntegrationFlowDefinition.() -> Unit): IntegrationFlow
fun integrationFlow(gatewaySpec: MessagingGatewaySpec<*, *>, flow: KotlinIntegrationFlowDefinition.() -> Unit): IntegrationFlow
fun integrationFlow(producer: MessageProducerSupport, flow: KotlinIntegrationFlowDefinition.() -> Unit): IntegrationFlow
fun integrationFlow(producerSpec: MessageProducerSpec<*, *>, flow: KotlinIntegrationFlowDefinition.() -> Unit): IntegrationFlow
class KotlinIntegrationFlowDefinition : BaseIntegrationFlowDefinition<KotlinIntegrationFlowDefinition>
Module Contents
KotlinIntegrationFlowDefinition(adaptee: IntegrationFlowDefinition<*>)
protected fun addComponent(component: Any): KotlinIntegrationFlowDefinition
protected fun addComponent(component: Any, beanName: String?): KotlinIntegrationFlowDefinition
protected fun addComponents(components: Map<Any, String>?): KotlinIntegrationFlowDefinition
inline fun <reified T> convert(crossinline configurer: (GenericEndpointSpec<MessageTransformingHandler>) -> Unit = {}): KotlinIntegrationFlowDefinition
protected fun currentComponent(component: Any?): KotlinIntegrationFlowDefinition
protected fun currentMessageChannel(currentMessageChannel: MessageChannel?): KotlinIntegrationFlowDefinition
inline fun <reified P> filter(crossinline function: (P) -> Boolean, crossinline configurer: (FilterEndpointSpec) -> Unit = {}): KotlinIntegrationFlowDefinition
protected fun getCurrentComponent(): Any?
protected fun getCurrentMessageChannel(): MessageChannel?
protected fun getIntegrationComponents(): Map<Any, String>
protected fun isImplicitChannel(): Boolean
inline fun <reified P, T> route(crossinline function: (P) -> T, crossinline configurer: (RouterSpec<T, MethodInvokingRouter>) -> Unit = {}): KotlinIntegrationFlowDefinition
protected fun setImplicitChannel(implicitChannel: Boolean): Unit
inline fun <reified P> split(crossinline function: (P) -> Any, crossinline configurer: (SplitterEndpointSpec<MethodInvokingSplitter>) -> Unit = {}): KotlinIntegrationFlowDefinition
inline fun <reified P, T> transform(crossinline function: (P) -> T, crossinline configurer: (GenericEndpointSpec<MessageTransformingHandler>) -> Unit = {}): KotlinIntegrationFlowDefinition