spring-integration
Module Contents
alltypes
Module Contents
abstract class AbstractKotlinRouterSpec<S : AbstractRouterSpec<S, R>, R : AbstractMessageRouter> : ConsumerEndpointSpec<S, R>
class KotlinEnricherSpec : ConsumerEndpointSpec<EnricherSpec, ContentEnricher>
Module Contents
KotlinEnricherSpec(delegate: EnricherSpec)
val delegate: EnricherSpec
fun errorChannel(errorChannel: MessageChannel): Unit
fun errorChannel(errorChannel: String): Unit
fun <V> header(: String, : V, : Boolean?): Unit
fun <V> header(: String, : HeaderValueMessageProcessor<V>): Unit
fun headerExpression(: String, : String, : Boolean?): Unit
fun <P> headerFunction(: String, : (Message<P>) -> Any, : Boolean?): Unit
fun <V> property(key: String, value: V): Unit
fun propertyExpression(key: String, expression: String): Unit
fun <P> propertyFunction(key: String, function: (Message<P>) -> Any): Unit
fun replyChannel(replyChannel: MessageChannel): Unit
fun replyChannel(replyChannel: String): Unit
fun replyTimeout(replyTimeout: Long): Unit
fun requestChannel(requestChannel: MessageChannel): Unit
fun requestChannel(requestChannel: String): Unit
fun <P> requestPayload(function: (Message<P>) -> Any): Unit
fun requestPayloadExpression(requestPayloadExpression: String): Unit
fun requestSubFlow(subFlow: KotlinIntegrationFlowDefinition.() -> Unit): Unit
fun requestTimeout(requestTimeout: Long): Unit
fun shouldClonePayload(shouldClonePayload: Boolean): Unit
class KotlinFilterEndpointSpec : ConsumerEndpointSpec<FilterEndpointSpec, MessageFilter>
class KotlinIntegrationFlowDefinition
Module Contents
KotlinIntegrationFlowDefinition(delegate: IntegrationFlowDefinition<*>)
fun aggregate(aggregator: AggregatorSpec.() -> Unit = {}): Unit
fun barrier(timeout: Long, barrierConfigurer: BarrierSpec.() -> Unit = {}): Unit
fun bridge(endpointConfigurer: GenericEndpointSpec<BridgeHandler>.() -> Unit = {}): Unit
fun channel(messageChannelName: String): Unit
fun channel(messageChannelSpec: MessageChannelSpec<*, *>): Unit
fun channel(messageChannel: MessageChannel): Unit
fun channel(channels: Channels.() -> MessageChannelSpec<*, *>): Unit
fun claimCheckIn(messageStore: MessageStore, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit = {}): Unit
fun claimCheckOut(messageStore: MessageStore, removeMessage: Boolean = false): Unit
fun claimCheckOut(messageStore: MessageStore, removeMessage: Boolean, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit): Unit
fun controlBus(endpointConfigurer: GenericEndpointSpec<ServiceActivatingHandler>.() -> Unit = {}): Unit
inline fun <reified T> convert(crossinline configurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit = {}): Unit
fun delay(groupId: String, endpointConfigurer: DelayerEndpointSpec.() -> Unit = {}): Unit
fun enrich(enricherConfigurer: KotlinEnricherSpec.() -> Unit): Unit
fun enrichHeaders(headers: MapBuilder<*, String, Any>, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit = {}): Unit
fun enrichHeaders(headers: Map<String, Any>, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit = {}): Unit
fun enrichHeaders(: HeaderEnricherSpec.() -> Unit): Unit
inline fun <reified P> filter(crossinline function: (P) -> Boolean): Unit
inline fun <reified P> filter(crossinline function: (P) -> Boolean, crossinline filterConfigurer: KotlinFilterEndpointSpec.() -> Unit): Unit
fun filter(expression: String, filterConfigurer: KotlinFilterEndpointSpec.() -> Unit = {}): Unit
fun filter(service: Any, methodName: String? = null): Unit
fun filter(service: Any, methodName: String?, filterConfigurer: KotlinFilterEndpointSpec.() -> Unit): Unit
fun filter(messageProcessorSpec: MessageProcessorSpec<*>, filterConfigurer: KotlinFilterEndpointSpec.() -> Unit = {}): Unit
fun filter(messageSelector: MessageSelector, filterConfigurer: KotlinFilterEndpointSpec.() -> Unit = {}): Unit
fun fixedSubscriberChannel(messageChannelName: String? = null): Unit
fun <I, O> fluxTransform(fluxFunction: (Flux<Message<I>>) -> Publisher<O>): Unit
fun gateway(requestChannel: String, endpointConfigurer: GatewayEndpointSpec.() -> Unit = {}): Unit
fun gateway(requestChannel: MessageChannel, endpointConfigurer: GatewayEndpointSpec.() -> Unit = {}): Unit
fun gateway(flow: KotlinIntegrationFlowDefinition.() -> Unit): Unit
fun gateway(endpointConfigurer: GatewayEndpointSpec.() -> Unit, flow: KotlinIntegrationFlowDefinition.() -> Unit): Unit
fun <H : MessageHandler?> handle(messageHandlerSpec: MessageHandlerSpec<*, H>): Unit
fun handle(messageHandler: MessageHandler): Unit
fun handle(beanName: String, methodName: String? = null): Unit
fun handle(beanName: String, methodName: String?, endpointConfigurer: GenericEndpointSpec<ServiceActivatingHandler>.() -> Unit): Unit
fun handle(service: Any, methodName: String? = null): Unit
fun handle(service: Any, methodName: String?, endpointConfigurer: GenericEndpointSpec<ServiceActivatingHandler>.() -> Unit): Unit
inline fun <reified P> handle(crossinline handler: (P, MessageHeaders) -> Any): Unit
inline fun <reified P> handle(crossinline handler: (P, MessageHeaders) -> Any, crossinline endpointConfigurer: GenericEndpointSpec<ServiceActivatingHandler>.() -> Unit): Unit
fun handle(messageProcessorSpec: MessageProcessorSpec<*>, endpointConfigurer: GenericEndpointSpec<ServiceActivatingHandler>.() -> Unit = {}): Unit
fun <H : MessageHandler> handle(messageHandlerSpec: MessageHandlerSpec<*, H>, endpointConfigurer: GenericEndpointSpec<H>.() -> Unit = {}): Unit
fun handle(messageHandler: (Message<*>) -> Unit): Unit
fun handle(messageHandler: (Message<*>) -> Unit, endpointConfigurer: GenericEndpointSpec<MessageHandler>.() -> Unit): Unit
fun <H : MessageHandler> handle(messageHandler: H, endpointConfigurer: GenericEndpointSpec<H>.() -> Unit = {}): Unit
fun headerFilter(: String, : Boolean = true): Unit
fun headerFilter(headerFilter: HeaderFilter, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit): Unit
fun log(): Unit
fun log(level: Level, category: String? = null): Unit
fun log(category: String): Unit
fun log(level: Level, category: String, logExpression: String): Unit
fun <P> log(function: (Message<P>) -> Any): Unit
fun log(logExpression: Expression): Unit
fun log(level: Level, logExpression: Expression): Unit
fun log(category: String, logExpression: Expression): Unit
fun <P> log(level: Level, function: (Message<P>) -> Any): Unit
fun <P> log(category: String, function: (Message<P>) -> Any): Unit
fun <P> log(level: Level, category: String, function: (Message<P>) -> Any): Unit
fun log(level: Level, category: String, logExpression: Expression): Unit
fun publishSubscribe(broadcastCapableChannel: BroadcastCapableChannel, vararg subscribeSubFlows: KotlinIntegrationFlowDefinition.() -> Unit): Unit
fun resequence(resequencer: ResequencerSpec.() -> Unit = {}): Unit
inline fun <reified P> route(crossinline function: (P) -> Any?): Unit
inline fun <reified P, T> route(crossinline function: (P) -> T, crossinline configurer: KotlinRouterSpec<T, MethodInvokingRouter>.() -> Unit): Unit
fun route(beanName: String, method: String? = null): Unit
fun route(beanName: String, method: String?, routerConfigurer: KotlinRouterSpec<Any, MethodInvokingRouter>.() -> Unit): Unit
fun route(service: Any, methodName: String? = null): Unit
fun route(service: Any, methodName: String?, routerConfigurer: KotlinRouterSpec<Any, MethodInvokingRouter>.() -> Unit): Unit
fun <T> route(expression: String, routerConfigurer: KotlinRouterSpec<T, ExpressionEvaluatingRouter>.() -> Unit = {}): Unit
fun route(messageProcessorSpec: MessageProcessorSpec<*>, routerConfigurer: KotlinRouterSpec<Any, MethodInvokingRouter>.() -> Unit = {}): Unit
fun <R : AbstractMessageRouter?> route(router: R, endpointConfigurer: GenericEndpointSpec<R>.() -> Unit = {}): Unit
fun routeByException(routerConfigurer: KotlinRouterSpec<Class<out Throwable>, ErrorMessageExceptionTypeRouter>.() -> Unit): Unit
fun routeToRecipients(routerConfigurer: KotlinRecipientListRouterSpec.() -> Unit): Unit
fun scatterGather(scatterChannel: MessageChannel, gatherer: AggregatorSpec.() -> Unit = {}): Unit
fun scatterGather(scatterChannel: MessageChannel, gatherer: AggregatorSpec.() -> Unit, scatterGather: ScatterGatherSpec.() -> Unit): Unit
fun scatterGather(scatterer: KotlinRecipientListRouterSpec.() -> Unit): Unit
fun scatterGather(scatterer: KotlinRecipientListRouterSpec.() -> Unit, gatherer: AggregatorSpec.() -> Unit): Unit
fun scatterGather(scatterer: KotlinRecipientListRouterSpec.() -> Unit, gatherer: AggregatorSpec.() -> Unit, scatterGather: ScatterGatherSpec.() -> Unit): Unit
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
fun split(): Unit
fun split(expression: String, endpointConfigurer: KotlinSplitterEndpointSpec<ExpressionEvaluatingSplitter>.() -> Unit = {}): Unit
fun split(service: Any, methodName: String? = null): Unit
fun split(service: Any, methodName: String?, splitterConfigurer: KotlinSplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit): Unit
fun split(beanName: String, methodName: String? = null): Unit
fun split(beanName: String, methodName: String?, splitterConfigurer: KotlinSplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit): Unit
fun split(messageProcessorSpec: MessageProcessorSpec<*>, splitterConfigurer: KotlinSplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit = {}): Unit
fun <S : AbstractMessageSplitter> split(splitterMessageHandlerSpec: MessageHandlerSpec<*, S>, splitterConfigurer: KotlinSplitterEndpointSpec<S>.() -> Unit = {}): Unit
fun <S : AbstractMessageSplitter> split(splitter: S, splitterConfigurer: KotlinSplitterEndpointSpec<S>.() -> Unit = {}): Unit
inline fun <reified P> transform(crossinline function: (P) -> Any): Unit
inline fun <reified P> transform(crossinline function: (P) -> Any, crossinline configurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit): Unit
fun transform(transformer: Transformer, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit = {}): Unit
fun transform(expression: String, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit = {}): Unit
fun transform(service: Any, methodName: String? = null): Unit
fun transform(service: Any, methodName: String?, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit): Unit
fun transform(messageProcessorSpec: MessageProcessorSpec<*>, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit = {}): Unit
fun trigger(triggerActionId: String, endpointConfigurer: GenericEndpointSpec<ServiceActivatingHandler>.() -> Unit = {}): Unit
fun trigger(triggerAction: MessageTriggerAction, endpointConfigurer: GenericEndpointSpec<ServiceActivatingHandler>.() -> Unit = {}): Unit
fun wireTap(flow: KotlinIntegrationFlowDefinition.() -> Unit): Unit
fun wireTap(wireTapConfigurer: WireTapSpec.() -> Unit, flow: KotlinIntegrationFlowDefinition.() -> Unit): Unit
fun wireTap(wireTapChannel: String, wireTapConfigurer: WireTapSpec.() -> Unit = {}): Unit
fun wireTap(wireTapChannel: MessageChannel, wireTapConfigurer: WireTapSpec.() -> Unit = {}): Unit
fun wireTap(wireTapSpec: WireTapSpec): Unit
class KotlinRecipientListRouterSpec : AbstractKotlinRouterSpec<RecipientListRouterSpec, RecipientListRouter>
class KotlinRouterSpec<K, R : AbstractMappingMessageRouter> : AbstractKotlinRouterSpec<RouterSpec<K, R>, R>
class KotlinSplitterEndpointSpec<H : AbstractMessageSplitter> : ConsumerEndpointSpec<KotlinSplitterEndpointSpec<H>, H>
package org.springframework.integration.dsl
Module Contents
abstract class AbstractKotlinRouterSpec<S : AbstractRouterSpec<S, R>, R : AbstractMessageRouter> : ConsumerEndpointSpec<S, R>
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 KotlinEnricherSpec : ConsumerEndpointSpec<EnricherSpec, ContentEnricher>
Module Contents
KotlinEnricherSpec(delegate: EnricherSpec)
val delegate: EnricherSpec
fun errorChannel(errorChannel: MessageChannel): Unit
fun errorChannel(errorChannel: String): Unit
fun <V> header(: String, : V, : Boolean?): Unit
fun <V> header(: String, : HeaderValueMessageProcessor<V>): Unit
fun headerExpression(: String, : String, : Boolean?): Unit
fun <P> headerFunction(: String, : (Message<P>) -> Any, : Boolean?): Unit
fun <V> property(key: String, value: V): Unit
fun propertyExpression(key: String, expression: String): Unit
fun <P> propertyFunction(key: String, function: (Message<P>) -> Any): Unit
fun replyChannel(replyChannel: MessageChannel): Unit
fun replyChannel(replyChannel: String): Unit
fun replyTimeout(replyTimeout: Long): Unit
fun requestChannel(requestChannel: MessageChannel): Unit
fun requestChannel(requestChannel: String): Unit
fun <P> requestPayload(function: (Message<P>) -> Any): Unit
fun requestPayloadExpression(requestPayloadExpression: String): Unit
fun requestSubFlow(subFlow: KotlinIntegrationFlowDefinition.() -> Unit): Unit
fun requestTimeout(requestTimeout: Long): Unit
fun shouldClonePayload(shouldClonePayload: Boolean): Unit
class KotlinFilterEndpointSpec : ConsumerEndpointSpec<FilterEndpointSpec, MessageFilter>
class KotlinIntegrationFlowDefinition
Module Contents
KotlinIntegrationFlowDefinition(delegate: IntegrationFlowDefinition<*>)
fun aggregate(aggregator: AggregatorSpec.() -> Unit = {}): Unit
fun barrier(timeout: Long, barrierConfigurer: BarrierSpec.() -> Unit = {}): Unit
fun bridge(endpointConfigurer: GenericEndpointSpec<BridgeHandler>.() -> Unit = {}): Unit
fun channel(messageChannelName: String): Unit
fun channel(messageChannelSpec: MessageChannelSpec<*, *>): Unit
fun channel(messageChannel: MessageChannel): Unit
fun channel(channels: Channels.() -> MessageChannelSpec<*, *>): Unit
fun claimCheckIn(messageStore: MessageStore, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit = {}): Unit
fun claimCheckOut(messageStore: MessageStore, removeMessage: Boolean = false): Unit
fun claimCheckOut(messageStore: MessageStore, removeMessage: Boolean, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit): Unit
fun controlBus(endpointConfigurer: GenericEndpointSpec<ServiceActivatingHandler>.() -> Unit = {}): Unit
inline fun <reified T> convert(crossinline configurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit = {}): Unit
fun delay(groupId: String, endpointConfigurer: DelayerEndpointSpec.() -> Unit = {}): Unit
fun enrich(enricherConfigurer: KotlinEnricherSpec.() -> Unit): Unit
fun enrichHeaders(headers: MapBuilder<*, String, Any>, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit = {}): Unit
fun enrichHeaders(headers: Map<String, Any>, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit = {}): Unit
fun enrichHeaders(: HeaderEnricherSpec.() -> Unit): Unit
inline fun <reified P> filter(crossinline function: (P) -> Boolean): Unit
inline fun <reified P> filter(crossinline function: (P) -> Boolean, crossinline filterConfigurer: KotlinFilterEndpointSpec.() -> Unit): Unit
fun filter(expression: String, filterConfigurer: KotlinFilterEndpointSpec.() -> Unit = {}): Unit
fun filter(service: Any, methodName: String? = null): Unit
fun filter(service: Any, methodName: String?, filterConfigurer: KotlinFilterEndpointSpec.() -> Unit): Unit
fun filter(messageProcessorSpec: MessageProcessorSpec<*>, filterConfigurer: KotlinFilterEndpointSpec.() -> Unit = {}): Unit
fun filter(messageSelector: MessageSelector, filterConfigurer: KotlinFilterEndpointSpec.() -> Unit = {}): Unit
fun fixedSubscriberChannel(messageChannelName: String? = null): Unit
fun <I, O> fluxTransform(fluxFunction: (Flux<Message<I>>) -> Publisher<O>): Unit
fun gateway(requestChannel: String, endpointConfigurer: GatewayEndpointSpec.() -> Unit = {}): Unit
fun gateway(requestChannel: MessageChannel, endpointConfigurer: GatewayEndpointSpec.() -> Unit = {}): Unit
fun gateway(flow: KotlinIntegrationFlowDefinition.() -> Unit): Unit
fun gateway(endpointConfigurer: GatewayEndpointSpec.() -> Unit, flow: KotlinIntegrationFlowDefinition.() -> Unit): Unit
fun <H : MessageHandler?> handle(messageHandlerSpec: MessageHandlerSpec<*, H>): Unit
fun handle(messageHandler: MessageHandler): Unit
fun handle(beanName: String, methodName: String? = null): Unit
fun handle(beanName: String, methodName: String?, endpointConfigurer: GenericEndpointSpec<ServiceActivatingHandler>.() -> Unit): Unit
fun handle(service: Any, methodName: String? = null): Unit
fun handle(service: Any, methodName: String?, endpointConfigurer: GenericEndpointSpec<ServiceActivatingHandler>.() -> Unit): Unit
inline fun <reified P> handle(crossinline handler: (P, MessageHeaders) -> Any): Unit
inline fun <reified P> handle(crossinline handler: (P, MessageHeaders) -> Any, crossinline endpointConfigurer: GenericEndpointSpec<ServiceActivatingHandler>.() -> Unit): Unit
fun handle(messageProcessorSpec: MessageProcessorSpec<*>, endpointConfigurer: GenericEndpointSpec<ServiceActivatingHandler>.() -> Unit = {}): Unit
fun <H : MessageHandler> handle(messageHandlerSpec: MessageHandlerSpec<*, H>, endpointConfigurer: GenericEndpointSpec<H>.() -> Unit = {}): Unit
fun handle(messageHandler: (Message<*>) -> Unit): Unit
fun handle(messageHandler: (Message<*>) -> Unit, endpointConfigurer: GenericEndpointSpec<MessageHandler>.() -> Unit): Unit
fun <H : MessageHandler> handle(messageHandler: H, endpointConfigurer: GenericEndpointSpec<H>.() -> Unit = {}): Unit
fun headerFilter(: String, : Boolean = true): Unit
fun headerFilter(headerFilter: HeaderFilter, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit): Unit
fun log(): Unit
fun log(level: Level, category: String? = null): Unit
fun log(category: String): Unit
fun log(level: Level, category: String, logExpression: String): Unit
fun <P> log(function: (Message<P>) -> Any): Unit
fun log(logExpression: Expression): Unit
fun log(level: Level, logExpression: Expression): Unit
fun log(category: String, logExpression: Expression): Unit
fun <P> log(level: Level, function: (Message<P>) -> Any): Unit
fun <P> log(category: String, function: (Message<P>) -> Any): Unit
fun <P> log(level: Level, category: String, function: (Message<P>) -> Any): Unit
fun log(level: Level, category: String, logExpression: Expression): Unit
fun publishSubscribe(broadcastCapableChannel: BroadcastCapableChannel, vararg subscribeSubFlows: KotlinIntegrationFlowDefinition.() -> Unit): Unit
fun resequence(resequencer: ResequencerSpec.() -> Unit = {}): Unit
inline fun <reified P> route(crossinline function: (P) -> Any?): Unit
inline fun <reified P, T> route(crossinline function: (P) -> T, crossinline configurer: KotlinRouterSpec<T, MethodInvokingRouter>.() -> Unit): Unit
fun route(beanName: String, method: String? = null): Unit
fun route(beanName: String, method: String?, routerConfigurer: KotlinRouterSpec<Any, MethodInvokingRouter>.() -> Unit): Unit
fun route(service: Any, methodName: String? = null): Unit
fun route(service: Any, methodName: String?, routerConfigurer: KotlinRouterSpec<Any, MethodInvokingRouter>.() -> Unit): Unit
fun <T> route(expression: String, routerConfigurer: KotlinRouterSpec<T, ExpressionEvaluatingRouter>.() -> Unit = {}): Unit
fun route(messageProcessorSpec: MessageProcessorSpec<*>, routerConfigurer: KotlinRouterSpec<Any, MethodInvokingRouter>.() -> Unit = {}): Unit
fun <R : AbstractMessageRouter?> route(router: R, endpointConfigurer: GenericEndpointSpec<R>.() -> Unit = {}): Unit
fun routeByException(routerConfigurer: KotlinRouterSpec<Class<out Throwable>, ErrorMessageExceptionTypeRouter>.() -> Unit): Unit
fun routeToRecipients(routerConfigurer: KotlinRecipientListRouterSpec.() -> Unit): Unit
fun scatterGather(scatterChannel: MessageChannel, gatherer: AggregatorSpec.() -> Unit = {}): Unit
fun scatterGather(scatterChannel: MessageChannel, gatherer: AggregatorSpec.() -> Unit, scatterGather: ScatterGatherSpec.() -> Unit): Unit
fun scatterGather(scatterer: KotlinRecipientListRouterSpec.() -> Unit): Unit
fun scatterGather(scatterer: KotlinRecipientListRouterSpec.() -> Unit, gatherer: AggregatorSpec.() -> Unit): Unit
fun scatterGather(scatterer: KotlinRecipientListRouterSpec.() -> Unit, gatherer: AggregatorSpec.() -> Unit, scatterGather: ScatterGatherSpec.() -> Unit): Unit
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
fun split(): Unit
fun split(expression: String, endpointConfigurer: KotlinSplitterEndpointSpec<ExpressionEvaluatingSplitter>.() -> Unit = {}): Unit
fun split(service: Any, methodName: String? = null): Unit
fun split(service: Any, methodName: String?, splitterConfigurer: KotlinSplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit): Unit
fun split(beanName: String, methodName: String? = null): Unit
fun split(beanName: String, methodName: String?, splitterConfigurer: KotlinSplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit): Unit
fun split(messageProcessorSpec: MessageProcessorSpec<*>, splitterConfigurer: KotlinSplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit = {}): Unit
fun <S : AbstractMessageSplitter> split(splitterMessageHandlerSpec: MessageHandlerSpec<*, S>, splitterConfigurer: KotlinSplitterEndpointSpec<S>.() -> Unit = {}): Unit
fun <S : AbstractMessageSplitter> split(splitter: S, splitterConfigurer: KotlinSplitterEndpointSpec<S>.() -> Unit = {}): Unit
inline fun <reified P> transform(crossinline function: (P) -> Any): Unit
inline fun <reified P> transform(crossinline function: (P) -> Any, crossinline configurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit): Unit
fun transform(transformer: Transformer, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit = {}): Unit
fun transform(expression: String, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit = {}): Unit
fun transform(service: Any, methodName: String? = null): Unit
fun transform(service: Any, methodName: String?, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit): Unit
fun transform(messageProcessorSpec: MessageProcessorSpec<*>, endpointConfigurer: GenericEndpointSpec<MessageTransformingHandler>.() -> Unit = {}): Unit
fun trigger(triggerActionId: String, endpointConfigurer: GenericEndpointSpec<ServiceActivatingHandler>.() -> Unit = {}): Unit
fun trigger(triggerAction: MessageTriggerAction, endpointConfigurer: GenericEndpointSpec<ServiceActivatingHandler>.() -> Unit = {}): Unit
fun wireTap(flow: KotlinIntegrationFlowDefinition.() -> Unit): Unit
fun wireTap(wireTapConfigurer: WireTapSpec.() -> Unit, flow: KotlinIntegrationFlowDefinition.() -> Unit): Unit
fun wireTap(wireTapChannel: String, wireTapConfigurer: WireTapSpec.() -> Unit = {}): Unit
fun wireTap(wireTapChannel: MessageChannel, wireTapConfigurer: WireTapSpec.() -> Unit = {}): Unit
fun wireTap(wireTapSpec: WireTapSpec): Unit
class KotlinRecipientListRouterSpec : AbstractKotlinRouterSpec<RecipientListRouterSpec, RecipientListRouter>
class KotlinRouterSpec<K, R : AbstractMappingMessageRouter> : AbstractKotlinRouterSpec<RouterSpec<K, R>, R>
class KotlinSplitterEndpointSpec<H : AbstractMessageSplitter> : ConsumerEndpointSpec<KotlinSplitterEndpointSpec<H>, H>