Package org.springframework.integration.dsl

Types

AbstractKotlinRouterSpec

abstract class AbstractKotlinRouterSpec<S : AbstractRouterSpec<S, R>, R : AbstractMessageRouter>(delegate: S) : KotlinConsumerEndpointSpec<S, R>

An AbstractRouterSpec wrapped for Kotlin DSL.

KotlinConsumerEndpointSpec

abstract class KotlinConsumerEndpointSpec<S : ConsumerEndpointSpec<S, H>, H : MessageHandler>(delegate: S) : ConsumerEndpointSpec<S, H>

A ConsumerEndpointSpec wrapped for Kotlin DSL.

KotlinEnricherSpec

class KotlinEnricherSpec(delegate: EnricherSpec) : KotlinConsumerEndpointSpec<EnricherSpec, ContentEnricher>

An EnricherSpec wrapped for Kotlin DSL.

KotlinFilterEndpointSpec

class KotlinFilterEndpointSpec(delegate: FilterEndpointSpec) : KotlinConsumerEndpointSpec<FilterEndpointSpec, MessageFilter>

An FilterEndpointSpec wrapped for Kotlin DSL.

KotlinIntegrationFlowDefinition

@IntegrationDsl

class KotlinIntegrationFlowDefinition(delegate: IntegrationFlowDefinition<*>)

An IntegrationFlowDefinition wrapped for Kotlin DSL.

KotlinRecipientListRouterSpec

class KotlinRecipientListRouterSpec(delegate: RecipientListRouterSpec) : AbstractKotlinRouterSpec<RecipientListRouterSpec, RecipientListRouter>

A RecipientListRouterSpec wrapped for Kotlin DSL.

KotlinRouterSpec

class KotlinRouterSpec<K, R : AbstractMappingMessageRouter>(delegate: RouterSpec<K, R>) : AbstractKotlinRouterSpec<RouterSpec<K, R>, R>

A RouterSpec wrapped for Kotlin DSL.

KotlinSplitterEndpointSpec

class KotlinSplitterEndpointSpec<H : AbstractMessageSplitter>(delegate: SplitterEndpointSpec<H>) : KotlinConsumerEndpointSpec<SplitterEndpointSpec<H>, H>

An SplitterEndpointSpec wrapped for Kotlin DSL.

Functions

integrationFlow

fun integrationFlow(flow: KotlinIntegrationFlowDefinition.() -> Unit): IntegrationFlow

Functional IntegrationFlow definition in Kotlin DSL for IntegrationFlow lambdas.

inline fun <T> integrationFlow(crossinline gateway: GatewayProxySpec.() -> Unit = {}, flow: KotlinIntegrationFlowDefinition.() -> Unit): IntegrationFlow

Functional IntegrationFlow definition in Kotlin DSL for IntegrationFlows.from - IntegrationFlows.from(Class<?>, Consumer<GatewayProxySpec>) factory method.

fun integrationFlow(publisher: Publisher<out Message<*>>, flow: KotlinIntegrationFlowDefinition.() -> Unit): StandardIntegrationFlow

Functional IntegrationFlow definition in Kotlin DSL for IntegrationFlows.from - IntegrationFlows.from(Publisher<out Message<*>>) factory method.

fun integrationFlow(sourceFlow: IntegrationFlow, flow: KotlinIntegrationFlowDefinition.() -> Unit): StandardIntegrationFlow

Functional IntegrationFlow definition in Kotlin DSL for IntegrationFlows.from - IntegrationFlows.from(IntegrationFlow) factory method.

fun integrationFlow(producerSpec: MessageProducerSpec<*, *>, flow: KotlinIntegrationFlowDefinition.() -> Unit): StandardIntegrationFlow

Functional IntegrationFlow definition in Kotlin DSL for IntegrationFlows.from - IntegrationFlows.from(MessageProducerSpec<*, *>) factory method.

fun integrationFlow(gatewaySpec: MessagingGatewaySpec<*, *>, flow: KotlinIntegrationFlowDefinition.() -> Unit): StandardIntegrationFlow

Functional IntegrationFlow definition in Kotlin DSL for IntegrationFlows.from - IntegrationFlows.from(MessagingGatewaySpec<*, *>) factory method.

fun integrationFlow(producer: MessageProducerSupport, flow: KotlinIntegrationFlowDefinition.() -> Unit): StandardIntegrationFlow

Functional IntegrationFlow definition in Kotlin DSL for IntegrationFlows.from - IntegrationFlows.from(MessageProducerSupport) factory method.

fun integrationFlow(gateway: MessagingGatewaySupport, flow: KotlinIntegrationFlowDefinition.() -> Unit): StandardIntegrationFlow

Functional IntegrationFlow definition in Kotlin DSL for IntegrationFlows.from - IntegrationFlows.from(MessagingGatewaySupport) factory method.

fun integrationFlow(channel: MessageChannel, flow: KotlinIntegrationFlowDefinition.() -> Unit): StandardIntegrationFlow

Functional IntegrationFlow definition in Kotlin DSL for IntegrationFlows.from - IntegrationFlows.from(MessageChannel) factory method.

fun integrationFlow(source: () -> Any, options: SourcePollingChannelAdapterSpec.() -> Unit = {}, flow: KotlinIntegrationFlowDefinition.() -> Unit): StandardIntegrationFlow

Functional IntegrationFlow definition in Kotlin DSL for IntegrationFlows.from - IntegrationFlows.from(Supplier<*>, Consumer<SourcePollingChannelAdapterSpec>) factory method.

fun integrationFlow(channelName: String, fixedSubscriber: Boolean = false, flow: KotlinIntegrationFlowDefinition.() -> Unit): StandardIntegrationFlow

Functional IntegrationFlow definition in Kotlin DSL for IntegrationFlows.from - IntegrationFlows.from(String, Boolean) factory method.

fun integrationFlow(messageSource: MessageSource<*>, options: SourcePollingChannelAdapterSpec.() -> Unit = {}, flow: KotlinIntegrationFlowDefinition.() -> Unit): StandardIntegrationFlow

Functional IntegrationFlow definition in Kotlin DSL for IntegrationFlows.from - IntegrationFlows.from(MessageSource<*>, Consumer<SourcePollingChannelAdapterSpec>) factory method.

fun integrationFlow(messageSource: MessageSourceSpec<*, out MessageSource<*>>, options: SourcePollingChannelAdapterSpec.() -> Unit = {}, flow: KotlinIntegrationFlowDefinition.() -> Unit): StandardIntegrationFlow

Functional IntegrationFlow definition in Kotlin DSL for IntegrationFlows.from - IntegrationFlows.from(MessageSourceSpec<*>, Consumer<SourcePollingChannelAdapterSpec>) factory method.