spring-integration
Module Contents
alltypes
Module Contents
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: EnricherSpec.() -> 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 configurer: FilterEndpointSpec.() -> Unit): Unit
fun filter(expression: String, endpointConfigurer: FilterEndpointSpec.() -> Unit = {}): Unit
fun filter(service: Any, methodName: String? = null): Unit
fun filter(service: Any, methodName: String?, endpointConfigurer: FilterEndpointSpec.() -> Unit): Unit
fun filter(messageProcessorSpec: MessageProcessorSpec<*>, endpointConfigurer: FilterEndpointSpec.() -> 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 publishSubscribeChannel(publishSubscribeChannelConfigurer: PublishSubscribeSpec.() -> Unit): Unit
fun publishSubscribeChannel(executor: Executor, publishSubscribeChannelConfigurer: PublishSubscribeSpec.() -> 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: RouterSpec<T, MethodInvokingRouter>.() -> Unit): Unit
fun route(beanName: String, method: String? = null): Unit
fun route(beanName: String, method: String?, routerConfigurer: RouterSpec<Any, MethodInvokingRouter>.() -> Unit): Unit
fun route(service: Any, methodName: String? = null): Unit
fun route(service: Any, methodName: String?, routerConfigurer: RouterSpec<Any, MethodInvokingRouter>.() -> Unit): Unit
fun <T> route(expression: String, routerConfigurer: RouterSpec<T, ExpressionEvaluatingRouter>.() -> Unit = {}): Unit
fun route(messageProcessorSpec: MessageProcessorSpec<*>, routerConfigurer: RouterSpec<Any, MethodInvokingRouter>.() -> Unit = {}): Unit
fun <R : AbstractMessageRouter?> route(router: R, endpointConfigurer: GenericEndpointSpec<R>.() -> Unit = {}): Unit
fun routeByException(routerConfigurer: RouterSpec<Class<out Throwable>, ErrorMessageExceptionTypeRouter>.() -> Unit): Unit
fun routeToRecipients(routerConfigurer: RecipientListRouterSpec.() -> Unit): Unit
fun scatterGather(scatterChannel: MessageChannel, gatherer: AggregatorSpec.() -> Unit = {}): Unit
fun scatterGather(scatterChannel: MessageChannel, gatherer: AggregatorSpec.() -> Unit, scatterGather: ScatterGatherSpec.() -> Unit): Unit
fun scatterGather(scatterer: RecipientListRouterSpec.() -> Unit): Unit
fun scatterGather(scatterer: RecipientListRouterSpec.() -> Unit, gatherer: AggregatorSpec.() -> Unit): Unit
fun scatterGather(scatterer: RecipientListRouterSpec.() -> 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: SplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit): Unit
fun split(): Unit
fun split(expression: String, endpointConfigurer: SplitterEndpointSpec<ExpressionEvaluatingSplitter>.() -> Unit = {}): Unit
fun split(service: Any, methodName: String? = null): Unit
fun split(service: Any, methodName: String?, endpointConfigurer: SplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit): Unit
fun split(beanName: String, methodName: String? = null): Unit
fun split(beanName: String, methodName: String?, endpointConfigurer: SplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit): Unit
fun split(messageProcessorSpec: MessageProcessorSpec<*>, endpointConfigurer: SplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit = {}): Unit
fun <S : AbstractMessageSplitter> split(splitterMessageHandlerSpec: MessageHandlerSpec<*, S>, endpointConfigurer: SplitterEndpointSpec<S>.() -> Unit = {}): Unit
fun <S : AbstractMessageSplitter> split(splitter: S, endpointConfigurer: SplitterEndpointSpec<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(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
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
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: EnricherSpec.() -> 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 configurer: FilterEndpointSpec.() -> Unit): Unit
fun filter(expression: String, endpointConfigurer: FilterEndpointSpec.() -> Unit = {}): Unit
fun filter(service: Any, methodName: String? = null): Unit
fun filter(service: Any, methodName: String?, endpointConfigurer: FilterEndpointSpec.() -> Unit): Unit
fun filter(messageProcessorSpec: MessageProcessorSpec<*>, endpointConfigurer: FilterEndpointSpec.() -> 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 publishSubscribeChannel(publishSubscribeChannelConfigurer: PublishSubscribeSpec.() -> Unit): Unit
fun publishSubscribeChannel(executor: Executor, publishSubscribeChannelConfigurer: PublishSubscribeSpec.() -> 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: RouterSpec<T, MethodInvokingRouter>.() -> Unit): Unit
fun route(beanName: String, method: String? = null): Unit
fun route(beanName: String, method: String?, routerConfigurer: RouterSpec<Any, MethodInvokingRouter>.() -> Unit): Unit
fun route(service: Any, methodName: String? = null): Unit
fun route(service: Any, methodName: String?, routerConfigurer: RouterSpec<Any, MethodInvokingRouter>.() -> Unit): Unit
fun <T> route(expression: String, routerConfigurer: RouterSpec<T, ExpressionEvaluatingRouter>.() -> Unit = {}): Unit
fun route(messageProcessorSpec: MessageProcessorSpec<*>, routerConfigurer: RouterSpec<Any, MethodInvokingRouter>.() -> Unit = {}): Unit
fun <R : AbstractMessageRouter?> route(router: R, endpointConfigurer: GenericEndpointSpec<R>.() -> Unit = {}): Unit
fun routeByException(routerConfigurer: RouterSpec<Class<out Throwable>, ErrorMessageExceptionTypeRouter>.() -> Unit): Unit
fun routeToRecipients(routerConfigurer: RecipientListRouterSpec.() -> Unit): Unit
fun scatterGather(scatterChannel: MessageChannel, gatherer: AggregatorSpec.() -> Unit = {}): Unit
fun scatterGather(scatterChannel: MessageChannel, gatherer: AggregatorSpec.() -> Unit, scatterGather: ScatterGatherSpec.() -> Unit): Unit
fun scatterGather(scatterer: RecipientListRouterSpec.() -> Unit): Unit
fun scatterGather(scatterer: RecipientListRouterSpec.() -> Unit, gatherer: AggregatorSpec.() -> Unit): Unit
fun scatterGather(scatterer: RecipientListRouterSpec.() -> 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: SplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit): Unit
fun split(): Unit
fun split(expression: String, endpointConfigurer: SplitterEndpointSpec<ExpressionEvaluatingSplitter>.() -> Unit = {}): Unit
fun split(service: Any, methodName: String? = null): Unit
fun split(service: Any, methodName: String?, endpointConfigurer: SplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit): Unit
fun split(beanName: String, methodName: String? = null): Unit
fun split(beanName: String, methodName: String?, endpointConfigurer: SplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit): Unit
fun split(messageProcessorSpec: MessageProcessorSpec<*>, endpointConfigurer: SplitterEndpointSpec<MethodInvokingSplitter>.() -> Unit = {}): Unit
fun <S : AbstractMessageSplitter> split(splitterMessageHandlerSpec: MessageHandlerSpec<*, S>, endpointConfigurer: SplitterEndpointSpec<S>.() -> Unit = {}): Unit
fun <S : AbstractMessageSplitter> split(splitter: S, endpointConfigurer: SplitterEndpointSpec<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(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