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

Link copied to clipboard
constructor(delegate: RouterSpec<K, R>)

Properties

Link copied to clipboard
open override val delegate: RouterSpec<K, R>

the RouterSpec this instance is delegating to.

Functions

Link copied to clipboard
fun advice(vararg advice: Advice?)
Link copied to clipboard
fun applySequence(applySequence: Boolean)
Link copied to clipboard
fun autoStartup(autoStartup: Boolean)
Link copied to clipboard
fun channelKeyFallback(channelKeyFallback: Boolean)
Link copied to clipboard
fun channelMapping(key: K & Any, channelName: String)
fun channelMapping(key: K & Any, channel: MessageChannel)
Link copied to clipboard
fun <T, V> customizeMonoReply(replyCustomizer: (Message<*>, Mono<T>) -> Publisher<V>)
Link copied to clipboard
fun defaultOutputChannel(channelName: String)
fun defaultOutputChannel(channel: MessageChannel)
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun dynamicChannelLimit(dynamicChannelLimit: Int)
Link copied to clipboard
fun handleMessageAdvice(vararg interceptors: MethodInterceptor?)
Link copied to clipboard
fun id(id: String?)
Link copied to clipboard
fun ignoreSendFailures(ignoreSendFailures: Boolean)
Link copied to clipboard
fun phase(phase: Int)
Link copied to clipboard
fun poller(pollers: (PollerFactory) -> PollerSpec)
fun poller(pollerMetadataSpec: PollerSpec)
fun poller(pollerMetadata: PollerMetadata)
Link copied to clipboard
fun prefix(prefix: String)
Link copied to clipboard
fun reactive()
fun reactive(reactiveCustomizer: (Flux<Message<*>>) -> Publisher<Message<*>>)
Link copied to clipboard
fun resolutionRequired(resolutionRequired: Boolean)
Link copied to clipboard
fun role(role: String)
Link copied to clipboard
fun subFlowMapping(key: K & Any, subFlow: KotlinIntegrationFlowDefinition.() -> Unit)
fun subFlowMapping(key: K & Any, subFlow: IntegrationFlow)
Link copied to clipboard
fun suffix(suffix: String)
Link copied to clipboard
fun taskScheduler(taskScheduler: TaskScheduler)
Link copied to clipboard
fun transactional()
fun transactional(handleMessageAdvice: Boolean)
fun transactional(transactionManager: TransactionManager)
fun transactional(transactionInterceptor: TransactionInterceptor)
fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean)