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

KotlinSplitterEndpointSpec

class KotlinSplitterEndpointSpec<H : AbstractMessageSplitter>(delegate: SplitterEndpointSpec<H>) : ConsumerEndpointSpec<KotlinSplitterEndpointSpec<H>, H>

An SplitterEndpointSpec wrapped for Kotlin DSL.

Author

Artem Bilan

Since

5.3

Constructors

KotlinSplitterEndpointSpec

fun <H : AbstractMessageSplitter> KotlinSplitterEndpointSpec(delegate: SplitterEndpointSpec<H>)

Functions

fun _this(): KotlinSplitterEndpointSpec<H>

open fun advice(vararg advice: Advice): KotlinSplitterEndpointSpec<H>

afterPropertiesSet

open override fun afterPropertiesSet()

fun applySequence(applySequence: Boolean)

open fun assertHandler()

open fun async(async: Boolean): KotlinSplitterEndpointSpec<H>

open override fun autoStartup(autoStartup: Boolean): KotlinSplitterEndpointSpec<H>

open override fun createInstance(): Tuple2<ConsumerEndpointFactoryBean, H>

customizeMonoReply

open fun <T : Any, V : Any> customizeMonoReply(replyCustomizer: BiFunction<Message<*>, Mono<T>, Publisher<V>>): KotlinSplitterEndpointSpec<H>

fun delimiters(delimiters: String)

open override fun destroy()

destroyInstance

open override fun destroyInstance(instance: Tuple2<ConsumerEndpointFactoryBean, H>)

fun discardChannel(discardChannelName: String)

fun discardChannel(discardChannel: MessageChannel)

fun discardFlow(discardFlow: KotlinIntegrationFlowDefinition.() -> Unit)

open override fun doGet(): Tuple2<ConsumerEndpointFactoryBean, H>

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

@Nullable

open fun getBeanFactory(): BeanFactory

getBeanTypeConverter

open fun getBeanTypeConverter(): TypeConverter

getComponentsToRegister

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

getEarlySingletonInterfaces

@Nullable

open fun getEarlySingletonInterfaces(): Array<Class<*>>

fun getId(): String

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

open override fun getObjectType(): Class<*>

open override fun getPhase(): Int

handleMessageAdvice

open fun handleMessageAdvice(vararg interceptors: MethodInterceptor): KotlinSplitterEndpointSpec<H>

open override fun id(id: String): KotlinSplitterEndpointSpec<H>

open override fun isAutoStartup(): Boolean

open override fun isRunning(): Boolean

open override fun isSingleton(): Boolean

notPropagatedHeaders

open fun notPropagatedHeaders(vararg headerPatterns: String): KotlinSplitterEndpointSpec<H>

obtainInputChannelFromFlow

open fun obtainInputChannelFromFlow(subFlow: IntegrationFlow): MessageChannel

open fun obtainInputChannelFromFlow(subFlow: IntegrationFlow, evaluateInternalBuilder: Boolean): MessageChannel

open fun order(order: Int): KotlinSplitterEndpointSpec<H>

open override fun phase(phase: Int): KotlinSplitterEndpointSpec<H>

open override fun poller(pollerMetadata: PollerMetadata): KotlinSplitterEndpointSpec<H>

open fun poller(pollers: Function<PollerFactory, PollerSpec>): KotlinSplitterEndpointSpec<H>

open fun poller(pollerMetadataSpec: PollerSpec): KotlinSplitterEndpointSpec<H>

open fun reactive(): KotlinSplitterEndpointSpec<H>

open fun reactive(reactiveCustomizer: Function<in Flux<Message<*>>, out Publisher<Message<*>>>): KotlinSplitterEndpointSpec<H>

open fun requiresReply(requiresReply: Boolean): KotlinSplitterEndpointSpec<H>

open override fun role(role: String): KotlinSplitterEndpointSpec<H>

open fun sendTimeout(sendTimeout: Long): KotlinSplitterEndpointSpec<H>

setBeanClassLoader

open override fun setBeanClassLoader(p0: ClassLoader)

open override fun setBeanFactory(@Nullable p0: BeanFactory)

open fun setSingleton(p0: Boolean)

open override fun start()

open override fun stop()

open override fun stop(callback: Runnable)

open fun taskScheduler(taskScheduler: TaskScheduler): KotlinSplitterEndpointSpec<H>

open fun transactional(): KotlinSplitterEndpointSpec<H>

open fun transactional(handleMessageAdvice: Boolean): KotlinSplitterEndpointSpec<H>

open fun transactional(transactionManager: TransactionManager): KotlinSplitterEndpointSpec<H>

open fun transactional(transactionInterceptor: TransactionInterceptor): KotlinSplitterEndpointSpec<H>

open fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean): KotlinSplitterEndpointSpec<H>

Properties

val adviceChain: MutableList<Advice>

componentsToRegister

val componentsToRegister: MutableMap<Any, String>

val delegate: SplitterEndpointSpec<H>

the SplitterEndpointSpec this instance is delegating to.

endpointFactoryBean

val endpointFactoryBean: ConsumerEndpointFactoryBean

val logger: Log

val target: Tuple2<ConsumerEndpointFactoryBean, H>