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

KotlinSplitterEndpointSpec

class ~~KotlinSplitterEndpointSpec~~<H : AbstractMessageSplitter>(val delegate: SplitterEndpointSpec<H>) : KotlinConsumerEndpointSpec<SplitterEndpointSpec<H>, H>

Deprecated

since 6.2

Replace with

KotlinSplitterSpec

An SplitterEndpointSpec wrapped for Kotlin DSL.

Author

Artem Bilan

Since

5.3

Constructors

KotlinSplitterEndpointSpec

constructor(delegate: SplitterEndpointSpec<H>)

Properties

delegate

open override val delegate: SplitterEndpointSpec<H>

the SplitterEndpointSpec this instance is delegating to.

@get:Nullable

val id: String

Functions

advice

open override fun advice(vararg advice: Advice?): SplitterEndpointSpec<H>

afterPropertiesSet

open override fun afterPropertiesSet()

applySequence

fun applySequence(applySequence: Boolean)

async

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

autoStartup

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

customizeMonoReply

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

fun <T, V> customizeMonoReply(replyCustomizer: (Message<*>, Mono<T>) -> Publisher<V>)

delimiters

fun delimiters(delimiters: String)

destroy

open override fun destroy()

discardChannel

fun discardChannel(discardChannelName: String)

fun discardChannel(discardChannel: MessageChannel)

discardFlow

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

fun discardFlow(discardFlow: IntegrationFlow)

getComponentsToRegister

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

getObject

@NonNull

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

getObjectType

open override fun getObjectType(): Class<*>

getPhase

open override fun getPhase(): Int

handleMessageAdvice

open override fun handleMessageAdvice(vararg interceptors: MethodInterceptor?): SplitterEndpointSpec<H>

open override fun id(id: String?): SplitterEndpointSpec<H>

isAutoStartup

open override fun isAutoStartup(): Boolean

isRunning

open override fun isRunning(): Boolean

isSingleton

open fun isSingleton(): Boolean

notPropagatedHeaders

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

order

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

phase

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

poller

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

fun poller(pollers: (PollerFactory) -> PollerSpec)

open override fun poller(pollerMetadataSpec: PollerSpec): SplitterEndpointSpec<H>

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

reactive

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

open override fun reactive(): SplitterEndpointSpec<H>

fun reactive(reactiveCustomizer: (Flux<Message<*>>) -> Publisher<Message<*>>)

requiresReply

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

role

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

sendTimeout

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

start

open override fun start()

stop

open override fun stop()

open override fun stop(callback: Runnable)

taskScheduler

open override fun taskScheduler(taskScheduler: TaskScheduler): SplitterEndpointSpec<H>

transactional

open override fun transactional(): SplitterEndpointSpec<H>

open override fun transactional(handleMessageAdvice: Boolean): SplitterEndpointSpec<H>

open override fun transactional(transactionManager: TransactionManager): SplitterEndpointSpec<H>

open override fun transactional(transactionInterceptor: TransactionInterceptor): SplitterEndpointSpec<H>

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