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

KotlinSplitterSpec

class KotlinSplitterSpec(val delegate: SplitterSpec) : KotlinConsumerEndpointSpec<SplitterSpec, AbstractMessageSplitter>

A SplitterSpec wrapped for Kotlin DSL.

Author

Artem Bilan

Since

6.2

Constructors

KotlinSplitterSpec

constructor(delegate: SplitterSpec)

Properties

open override val delegate: SplitterSpec

the ConsumerEndpointSpec this instance is delegating to.

Functions

fun advice(vararg advice: Advice?)

fun applySequence(applySequence: Boolean)

Set the applySequence flag to the specified value. Defaults to true.

fun autoStartup(autoStartup: Boolean)

customizeMonoReply

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

fun delimiters(delimiters: String)

Set delimiters to tokenize String values. The default is null indicating that no tokenizing should occur. If delimiters are provided, they will be applied to any String payload. Only applied if provided splitter is instance of DefaultMessageSplitter.

fun discardChannel(discardChannelName: String)

Specify a channel bean name where rejected Messages should be sent. If the discard channel is null (the default), rejected Messages will be dropped. A "Rejected Message" means that split function has returned an empty result (but not null): no items to iterate for sending.

fun discardChannel(discardChannel: MessageChannel)

Specify a channel where rejected Messages should be sent. If the discard channel is null (the default), rejected Messages will be dropped. A "Rejected Message" means that split function has returned an empty result (but not null): no items to iterate for sending.

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

Configure a subflow to run for discarded messages instead of a discardChannel.

fun expression(expression: String)

fun expression(expression: Expression)

Provide an expression to use an ExpressionEvaluatingSplitter for the target handler.

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

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

handleMessageAdvice

fun handleMessageAdvice(vararg interceptors: MethodInterceptor?)

fun id(id: String?)

fun method(method: String?)

Provide a service method name to call. Optional. Use only together with .ref or .refName.

fun phase(phase: Int)

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

fun poller(pollerMetadataSpec: PollerSpec)

fun poller(pollerMetadata: PollerMetadata)

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

fun ref(ref: Any)

Provide a service to use a MethodInvokingSplitter for the target handler. This option can be set to an AbstractMessageSplitter implementation, a MessageHandlerSpec providing an AbstractMessageSplitter, or MessageProcessorSpec.

fun refName(refName: String)

Provide a bean name to use a MethodInvokingSplitter (based on BeanNameMessageProcessor) for the target handler.

fun role(role: String)

fun taskScheduler(taskScheduler: TaskScheduler)

fun transactional()

fun transactional(handleMessageAdvice: Boolean)

fun transactional(transactionManager: TransactionManager)

fun transactional(transactionInterceptor: TransactionInterceptor)

fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean)