spring-integration-core/org.springframework.integration.dsl/KotlinRouterSpec

KotlinRouterSpec

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

A RouterSpec wrapped for Kotlin DSL.

Author

Artem Bilan

Since

5.3

Constructors

KotlinRouterSpec

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

Functions

advice

open fun advice(vararg advice: Advice): RouterSpec<K, R>

afterPropertiesSet

open override fun afterPropertiesSet()

applySequence

fun applySequence(applySequence: Boolean)

async

open fun async(async: Boolean): RouterSpec<K, R>

autoStartup

open override fun autoStartup(autoStartup: Boolean): RouterSpec<K, R>

channelKeyFallback

fun channelKeyFallback(channelKeyFallback: Boolean)

channelMapping

fun channelMapping(key: K, channelName: String)

fun channelMapping(key: K, channel: MessageChannel)

customizeMonoReply

open fun <T : Any, V : Any> customizeMonoReply(replyCustomizer: BiFunction<Message<*>, Mono<T>, Publisher<V>>): RouterSpec<K, R>

defaultOutputChannel

fun defaultOutputChannel(channelName: String)

fun defaultOutputChannel(channel: MessageChannel)

defaultOutputToParentFlow

fun defaultOutputToParentFlow()

defaultSubFlowMapping

fun defaultSubFlowMapping(subFlow: KotlinIntegrationFlowDefinition.() -> Unit)

destroy

open override fun destroy()

dynamicChannelLimit

fun dynamicChannelLimit(dynamicChannelLimit: Int)

get

open fun get(): Tuple2<ConsumerEndpointFactoryBean, R>

getComponentsToRegister

open override fun getComponentsToRegister(): MutableMap<Any, String>

getObject

override fun getObject(): Tuple2<ConsumerEndpointFactoryBean, R>

getObjectType

open override fun getObjectType(): Class<*>

getPhase

open override fun getPhase(): Int

handleMessageAdvice

open fun handleMessageAdvice(vararg interceptors: MethodInterceptor): RouterSpec<K, R>

open override fun id(id: String): RouterSpec<K, R>

ignoreSendFailures

fun ignoreSendFailures(ignoreSendFailures: Boolean)

isAutoStartup

open override fun isAutoStartup(): Boolean

isRunning

open override fun isRunning(): Boolean

noChannelKeyFallback

fun ~~noChannelKeyFallback~~()

notPropagatedHeaders

open fun notPropagatedHeaders(vararg headerPatterns: String): RouterSpec<K, R>

order

open fun order(order: Int): RouterSpec<K, R>

phase

open override fun phase(phase: Int): RouterSpec<K, R>

poller

open override fun poller(pollerMetadata: PollerMetadata): RouterSpec<K, R>

open fun poller(pollers: Function<PollerFactory, PollerSpec>): RouterSpec<K, R>

open fun poller(pollerMetadataSpec: PollerSpec): RouterSpec<K, R>

prefix

fun prefix(prefix: String)

reactive

open fun reactive(): RouterSpec<K, R>

open fun reactive(reactiveCustomizer: Function<in Flux<Message<*>>, out Publisher<Message<*>>>): RouterSpec<K, R>

requiresReply

open fun requiresReply(requiresReply: Boolean): RouterSpec<K, R>

resolutionRequired

fun resolutionRequired(resolutionRequired: Boolean)

role

open override fun role(role: String): RouterSpec<K, R>

sendTimeout

open fun sendTimeout(sendTimeout: Long): RouterSpec<K, R>

setBeanClassLoader

open override fun setBeanClassLoader(classLoader: ClassLoader)

start

open override fun start()

stop

open override fun stop()

open override fun stop(callback: Runnable)

subFlowMapping

fun subFlowMapping(key: K, subFlow: KotlinIntegrationFlowDefinition.() -> Unit)

suffix

fun suffix(suffix: String)

taskScheduler

open fun taskScheduler(taskScheduler: TaskScheduler): RouterSpec<K, R>

transactional

open fun transactional(): RouterSpec<K, R>

open fun transactional(handleMessageAdvice: Boolean): RouterSpec<K, R>

open fun transactional(transactionManager: TransactionManager): RouterSpec<K, R>

open fun transactional(transactionInterceptor: TransactionInterceptor): RouterSpec<K, R>

open fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean): RouterSpec<K, R>

Properties

beanFactory

@Nullable

protected var beanFactory: BeanFactory

delegate

open override val delegate: RouterSpec<K, R>

the RouterSpec this instance is delegating to.

val id: String

singleton

var singleton: Boolean