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

KotlinTransformerEndpointSpec

class KotlinTransformerEndpointSpec(val delegate: TransformerEndpointSpec) : KotlinConsumerEndpointSpec<TransformerEndpointSpec, MessageTransformingHandler>

A TransformerEndpointSpec wrapped for Kotlin DSL.

Author

Artem Bilan

Since

6.2

Constructors

KotlinTransformerEndpointSpec

constructor(delegate: TransformerEndpointSpec)

Properties

delegate

open override val delegate: TransformerEndpointSpec

the TransformerEndpointSpec this instance is delegating to.

Functions

advice

fun advice(vararg advice: Advice)

autoStartup

fun autoStartup(autoStartup: Boolean)

customizeMonoReply

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

expression

fun expression(expression: String)

fun expression(expression: Expression)

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

handleMessageAdvice

fun handleMessageAdvice(vararg interceptors: MethodInterceptor)

fun id(id: String)

method

fun method(method: String?)

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

phase

fun phase(phase: Int)

poller

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

fun poller(pollerMetadataSpec: PollerSpec)

fun poller(pollerMetadata: PollerMetadata)

processor

fun processor(processor: MessageProcessorSpec<*>)

Provide a MessageProcessorSpec as a factory for MethodInvokingTransformer delegate.

reactive

fun reactive()

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

ref

fun ref(ref: Any)

Provide a service to use a MethodInvokingTransformer for the target handler.

refName

fun refName(refName: String)

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

role

fun role(role: String)

taskScheduler

fun taskScheduler(taskScheduler: TaskScheduler)

transactional

fun transactional()

fun transactional(handleMessageAdvice: Boolean)

fun transactional(transactionManager: TransactionManager)

fun transactional(transactionInterceptor: TransactionInterceptor)

fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean)

transformer

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

Provide a Kotlin function as a direct delegate for MessageTransformingHandler.

fun <P : Any, T : Any> transformer(transformer: GenericTransformer<P, T>)

Provide a GenericTransformer as a direct delegate for MessageTransformingHandler.