KotlinRecipientListRouterSpec
class KotlinRecipientListRouterSpec(val delegate: RecipientListRouterSpec) : AbstractKotlinRouterSpec<RecipientListRouterSpec, RecipientListRouter>
Content copied to clipboard
A RecipientListRouterSpec wrapped for Kotlin DSL.
Author
Artem Bilan
Since
5.3
Constructors
Functions
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override fun autoStartup(autoStartup: Boolean): RecipientListRouterSpec
Content copied to clipboard
Link copied to clipboard
open fun <T : Any, V : Any> customizeMonoReply(replyCustomizer: BiFunction<Message<*>, Mono<T>, Publisher<V>>): RecipientListRouterSpec
Content copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun defaultSubFlowMapping(subFlow: KotlinIntegrationFlowDefinition.() -> Unit)
Content copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
override fun getObject(): Tuple2<ConsumerEndpointFactoryBean, RecipientListRouter>
Content copied to clipboard
Link copied to clipboard
Link copied to clipboard
open fun handleMessageAdvice(vararg interceptors: MethodInterceptor): RecipientListRouterSpec
Content copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open fun notPropagatedHeaders(vararg headerPatterns: String): RecipientListRouterSpec
Content copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override fun poller(pollerMetadata: PollerMetadata): RecipientListRouterSpec
Content copied to clipboard
open fun poller(pollers: Function<PollerFactory, PollerSpec>): RecipientListRouterSpec
Content copied to clipboard
Link copied to clipboard
open fun reactive(reactiveCustomizer: Function<in Flux<Message<*>>, out Publisher<Message<*>>>): RecipientListRouterSpec
Content copied to clipboard
Link copied to clipboard
inline fun <P> recipientFlow(crossinline selector: (P) -> Boolean, crossinline subFlow: KotlinIntegrationFlowDefinition.() -> Unit)
Content copied to clipboard
fun recipientFlow(expression: String, subFlow: KotlinIntegrationFlowDefinition.() -> Unit)
Content copied to clipboard
fun recipientFlow(expression: Expression, subFlow: KotlinIntegrationFlowDefinition.() -> Unit)
Content copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open fun taskScheduler(taskScheduler: TaskScheduler): RecipientListRouterSpec
Content copied to clipboard
Link copied to clipboard
open fun transactional(handleMessageAdvice: Boolean): RecipientListRouterSpec
Content copied to clipboard
open fun transactional(transactionManager: TransactionManager): RecipientListRouterSpec
Content copied to clipboard
open fun transactional(transactionInterceptor: TransactionInterceptor): RecipientListRouterSpec
Content copied to clipboard
open fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean): RecipientListRouterSpec
Content copied to clipboard
Properties
Link copied to clipboard
the RecipientListRouterSpec this instance is delegating to.