Package org.springframework.integration.dsl

Types

AbstractKotlinRouterSpec
Link copied to clipboard
abstract class AbstractKotlinRouterSpec<S : AbstractRouterSpec<S, R>, R : AbstractMessageRouter>(delegate: S) : KotlinConsumerEndpointSpec<S, R>

An AbstractRouterSpec wrapped for Kotlin DSL.

KotlinConsumerEndpointSpec
Link copied to clipboard
abstract class KotlinConsumerEndpointSpec<S : ConsumerEndpointSpec<S, H>, H : MessageHandler>(delegate: S) : ConsumerEndpointSpec<S, H>

A ConsumerEndpointSpec wrapped for Kotlin DSL.

KotlinEnricherSpec
Link copied to clipboard

An EnricherSpec wrapped for Kotlin DSL.

KotlinFilterEndpointSpec
Link copied to clipboard

An FilterEndpointSpec wrapped for Kotlin DSL.

KotlinIntegrationFlowDefinition
Link copied to clipboard
class KotlinIntegrationFlowDefinition(delegate: IntegrationFlowDefinition<*>)

An IntegrationFlowDefinition wrapped for Kotlin DSL.

KotlinRouterSpec
Link copied to clipboard
class KotlinRouterSpec<K, R : AbstractMappingMessageRouter>(delegate: RouterSpec<K, R>) : AbstractKotlinRouterSpec<RouterSpec<K, R>, R>

A RouterSpec wrapped for Kotlin DSL.

KotlinSplitterEndpointSpec
Link copied to clipboard

Functions

integrationFlow
Link copied to clipboard
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.

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

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.