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

KotlinRecipientListRouterSpec

class KotlinRecipientListRouterSpec(val delegate: RecipientListRouterSpec) : AbstractKotlinRouterSpec<RecipientListRouterSpec, RecipientListRouter>

A RecipientListRouterSpec wrapped for Kotlin DSL.

Author

Artem Bilan

Since

5.3

Constructors

Link copied to clipboard
constructor(delegate: RecipientListRouterSpec)

Properties

Link copied to clipboard
open override val delegate: RecipientListRouterSpec

the RecipientListRouterSpec this instance is delegating to.

Link copied to clipboard
@get:Nullable
val id: String

Functions

Link copied to clipboard
open override fun advice(vararg advice: Advice?): RecipientListRouterSpec
Link copied to clipboard
open override fun afterPropertiesSet()
Link copied to clipboard
fun applySequence(applySequence: Boolean)
Link copied to clipboard
Link copied to clipboard
open override fun autoStartup(autoStartup: Boolean): RecipientListRouterSpec
Link copied to clipboard
open fun <T : Any, V : Any> customizeMonoReply(replyCustomizer: BiFunction<Message<*>, Mono<T>, Publisher<V>>): RecipientListRouterSpec
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
open override fun destroy()
Link copied to clipboard
open override fun getComponentsToRegister(): MutableMap<Any, String>
Link copied to clipboard
Link copied to clipboard
open override fun getObjectType(): Class<*>
Link copied to clipboard
open override fun getPhase(): Int
Link copied to clipboard
open override fun handleMessageAdvice(vararg interceptors: MethodInterceptor?): RecipientListRouterSpec
Link copied to clipboard
open override fun id(id: String?): RecipientListRouterSpec
Link copied to clipboard
fun ignoreSendFailures(ignoreSendFailures: Boolean)
Link copied to clipboard
open override fun isAutoStartup(): Boolean
Link copied to clipboard
open override fun isRunning(): Boolean
Link copied to clipboard
open fun isSingleton(): Boolean
Link copied to clipboard
open fun notPropagatedHeaders(vararg headerPatterns: String): RecipientListRouterSpec
Link copied to clipboard
open fun order(order: Int): RecipientListRouterSpec
Link copied to clipboard
open override fun phase(phase: Int): RecipientListRouterSpec
Link copied to clipboard
open fun poller(pollers: Function<PollerFactory, PollerSpec>): RecipientListRouterSpec
fun poller(pollers: (PollerFactory) -> PollerSpec)
open override fun poller(pollerMetadataSpec: PollerSpec): RecipientListRouterSpec
open override fun poller(pollerMetadata: PollerMetadata): RecipientListRouterSpec
Link copied to clipboard
open fun reactive(reactiveCustomizer: Function<in Flux<Message<*>>, out Publisher<Message<*>>>): RecipientListRouterSpec
open override fun reactive(): RecipientListRouterSpec
fun reactive(reactiveCustomizer: (Flux<Message<*>>) -> Publisher<Message<*>>)
Link copied to clipboard
inline fun <P> recipient(channelName: String, crossinline selector: (P) -> Boolean)
fun recipient(channelName: String, expression: String? = null)
fun recipient(channelName: String, expression: Expression)
inline fun <P> recipient(channel: MessageChannel, crossinline selector: (P) -> Boolean)
fun recipient(channel: MessageChannel, expression: String? = null)
fun recipient(channel: MessageChannel, expression: Expression)
Link copied to clipboard
fun recipientFlow(subFlow: KotlinIntegrationFlowDefinition.() -> Unit)
fun recipientFlow(subFlow: IntegrationFlow)
inline fun <P> recipientFlow(crossinline selector: (P) -> Boolean, crossinline subFlow: KotlinIntegrationFlowDefinition.() -> Unit)
fun recipientFlow(expression: String, subFlow: KotlinIntegrationFlowDefinition.() -> Unit)
fun recipientFlow(expression: String, subFlow: IntegrationFlow)
fun recipientFlow(expression: Expression, subFlow: KotlinIntegrationFlowDefinition.() -> Unit)
fun recipientFlow(expression: Expression, subFlow: IntegrationFlow)
Link copied to clipboard
open fun requiresReply(requiresReply: Boolean): RecipientListRouterSpec
Link copied to clipboard
open override fun role(role: String): RecipientListRouterSpec
Link copied to clipboard
open fun sendTimeout(sendTimeout: Long): RecipientListRouterSpec
Link copied to clipboard
open override fun start()
Link copied to clipboard
open override fun stop()
open override fun stop(callback: Runnable)
Link copied to clipboard
open override fun taskScheduler(taskScheduler: TaskScheduler): RecipientListRouterSpec
Link copied to clipboard
open override fun transactional(): RecipientListRouterSpec
open override fun transactional(handleMessageAdvice: Boolean): RecipientListRouterSpec
open override fun transactional(transactionManager: TransactionManager): RecipientListRouterSpec
open override fun transactional(transactionInterceptor: TransactionInterceptor): RecipientListRouterSpec
open override fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean): RecipientListRouterSpec