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

KotlinEnricherSpec

class KotlinEnricherSpec(val delegate: EnricherSpec) : KotlinConsumerEndpointSpec<EnricherSpec, ContentEnricher>

An EnricherSpec wrapped for Kotlin DSL.

Author

Artem Bilan

Since

5.3

Constructors

Link copied to clipboard
constructor(delegate: EnricherSpec)

Properties

Link copied to clipboard
open override val delegate: EnricherSpec

the EnricherSpec this instance is delegating to.

Functions

Link copied to clipboard
fun advice(vararg advice: Advice?)
Link copied to clipboard
fun autoStartup(autoStartup: Boolean)
Link copied to clipboard
fun <T, V> customizeMonoReply(replyCustomizer: (Message<*>, Mono<T>) -> Publisher<V>)
Link copied to clipboard
fun errorChannel(errorChannel: String)
fun errorChannel(errorChannel: MessageChannel)
Link copied to clipboard
fun handleMessageAdvice(vararg interceptors: MethodInterceptor?)
Link copied to clipboard
fun header(headerName: String, headerValueMessageProcessor: HeaderValueMessageProcessor<Any>)
fun header(name: String, value: Any, overwrite: Boolean?)
Link copied to clipboard
fun headerExpression(name: String, expression: String, overwrite: Boolean?)
Link copied to clipboard
fun <P> headerFunction(name: String, function: (Message<P>) -> Any, overwrite: Boolean?)
Link copied to clipboard
fun id(id: String?)
Link copied to clipboard
fun phase(phase: Int)
Link copied to clipboard
fun poller(pollers: (PollerFactory) -> PollerSpec)
fun poller(pollerMetadataSpec: PollerSpec)
fun poller(pollerMetadata: PollerMetadata)
Link copied to clipboard
fun property(key: String, value: Any)
Link copied to clipboard
fun propertyExpression(key: String, expression: String)
Link copied to clipboard
fun <P> propertyFunction(key: String, function: (Message<P>) -> Any)
Link copied to clipboard
fun reactive()
fun reactive(reactiveCustomizer: (Flux<Message<*>>) -> Publisher<Message<*>>)
Link copied to clipboard
fun replyChannel(replyChannel: String)
fun replyChannel(replyChannel: MessageChannel)
Link copied to clipboard
fun replyTimeout(replyTimeout: Long)
Link copied to clipboard
fun requestChannel(requestChannel: String)
fun requestChannel(requestChannel: MessageChannel)
Link copied to clipboard
fun <P> requestPayload(function: (Message<P>) -> Any)
Link copied to clipboard
fun requestPayloadExpression(requestPayloadExpression: String)
Link copied to clipboard
Link copied to clipboard
fun requestTimeout(requestTimeout: Long)
Link copied to clipboard
fun role(role: String)
Link copied to clipboard
fun shouldClonePayload(shouldClonePayload: Boolean)
Link copied to clipboard
fun taskScheduler(taskScheduler: TaskScheduler)
Link copied to clipboard
fun transactional()
fun transactional(handleMessageAdvice: Boolean)
fun transactional(transactionManager: TransactionManager)
fun transactional(transactionInterceptor: TransactionInterceptor)
fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean)