KotlinRecipientListRouterSpec

Constructors

Functions

Link copied to clipboard
open 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
Link copied to clipboard
fun defaultOutputChannel(channelName: String)
fun defaultOutputChannel(channel: MessageChannel)
Link copied to clipboard
Link copied to clipboard
open override fun destroy()
Link copied to clipboard
Link copied to clipboard
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 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 notPropagatedHeaders(vararg headerPatterns: String): RecipientListRouterSpec
Link copied to clipboard
Link copied to clipboard
open override fun phase(phase: Int): RecipientListRouterSpec
Link copied to clipboard
open override fun poller(pollerMetadata: PollerMetadata): RecipientListRouterSpec
open fun poller(pollerMetadataSpec: PollerSpec): RecipientListRouterSpec
Link copied to clipboard
open fun reactive(reactiveCustomizer: Function<in Flux<Message<*>>, out Publisher<Message<*>>>): RecipientListRouterSpec
Link copied to clipboard
fun recipient(channelName: String)
fun recipient(channel: MessageChannel)
inline fun <P> recipient(channelName: String, crossinline selector: (P) -> Boolean)
fun recipient(channelName: String, expression: String)
fun recipient(channelName: String, expression: Expression)
inline fun <P> recipient(channel: MessageChannel, crossinline selector: (P) -> Boolean)
fun recipient(channel: MessageChannel, expression: String)
fun recipient(channel: MessageChannel, expression: Expression)
Link copied to clipboard
inline fun <P> recipientFlow(crossinline selector: (P) -> Boolean, crossinline subFlow: KotlinIntegrationFlowDefinition.() -> Unit)
fun recipientFlow(expression: String, subFlow: KotlinIntegrationFlowDefinition.() -> Unit)
fun recipientFlow(expression: Expression, subFlow: KotlinIntegrationFlowDefinition.() -> Unit)
Link copied to clipboard
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 setBeanClassLoader(classLoader: ClassLoader)
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 fun taskScheduler(taskScheduler: TaskScheduler): RecipientListRouterSpec
Link copied to clipboard
open fun transactional(handleMessageAdvice: Boolean): RecipientListRouterSpec
open fun transactional(transactionManager: TransactionManager): RecipientListRouterSpec
open fun transactional(transactionInterceptor: TransactionInterceptor): RecipientListRouterSpec
open fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean): RecipientListRouterSpec

Properties

Link copied to clipboard
@Nullable
protected var beanFactory: BeanFactory
Link copied to clipboard

the RecipientListRouterSpec this instance is delegating to.

Link copied to clipboard
val id: String
Link copied to clipboard