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

KotlinSplitterSpec

class KotlinSplitterSpec : SplitterSpec

A SplitterSpec wrapped for Kotlin DSL.

Author

Artem Bilan

Since

6.2

Constructors

KotlinSplitterSpec

constructor()

Properties

@get:Nullable

val id: String

Functions

advice

open fun advice(vararg advice: Advice): SplitterSpec

afterPropertiesSet

open override fun afterPropertiesSet()

applySequence

open fun applySequence(applySequence: Boolean): SplitterSpec

async

open fun async(async: Boolean): SplitterSpec

autoStartup

open override fun autoStartup(autoStartup: Boolean): SplitterSpec

customizeMonoReply

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

delimiters

open fun delimiters(delimiters: String): SplitterSpec

destroy

open override fun destroy()

discardChannel

open fun discardChannel(discardChannelName: String): SplitterSpec

open fun discardChannel(discardChannel: MessageChannel): SplitterSpec

discardFlow

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

open fun discardFlow(discardFlow: IntegrationFlow): SplitterSpec

doGet

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

expectedType

open fun expectedType(@Nullable expectedType: Class<*>): SplitterSpec

expression

open fun expression(expression: String): SplitterSpec

open fun expression(expression: Expression): SplitterSpec

function

inline fun <P> function(crossinline function: (P) -> Any)

Provide a Kotlin function as a direct delegate for org.springframework.integration.splitter.MethodInvokingSplitter.

open fun <P : Any> function(function: Function<P, *>): SplitterSpec

getComponentsToRegister

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

getObject

@NonNull

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

getObjectType

open override fun getObjectType(): Class<*>

getPhase

open override fun getPhase(): Int

handleMessageAdvice

open fun handleMessageAdvice(vararg interceptors: MethodInterceptor): SplitterSpec

open override fun id(@Nullable id: String): SplitterSpec

isAutoStartup

open override fun isAutoStartup(): Boolean

isRunning

open override fun isRunning(): Boolean

isSingleton

open fun isSingleton(): Boolean

method

open fun method(@Nullable method: String): SplitterSpec

notPropagatedHeaders

open fun notPropagatedHeaders(vararg headerPatterns: String): SplitterSpec

order

open fun order(order: Int): SplitterSpec

phase

open override fun phase(phase: Int): SplitterSpec

poller

open override fun poller(pollerMetadata: PollerMetadata): SplitterSpec

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

open fun poller(pollerMetadataSpec: PollerSpec): SplitterSpec

reactive

open fun reactive(): SplitterSpec

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

ref

open fun ref(ref: Any): SplitterSpec

refName

open fun refName(refName: String): SplitterSpec

requiresReply

open fun requiresReply(requiresReply: Boolean): SplitterSpec

role

open override fun role(role: String): SplitterSpec

sendTimeout

open fun sendTimeout(sendTimeout: Long): SplitterSpec

start

open override fun start()

stop

open override fun stop()

open override fun stop(callback: Runnable)

taskScheduler

open fun taskScheduler(taskScheduler: TaskScheduler): SplitterSpec

transactional

open fun transactional(): SplitterSpec

open fun transactional(handleMessageAdvice: Boolean): SplitterSpec

open fun transactional(transactionManager: TransactionManager): SplitterSpec

open fun transactional(transactionInterceptor: TransactionInterceptor): SplitterSpec

open fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean): SplitterSpec