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

KotlinEnricherSpec

constructor(delegate: EnricherSpec)

Properties

delegate

open override val delegate: EnricherSpec

the EnricherSpec this instance is delegating to.

@get:Nullable

val id: String

Functions

advice

open override fun advice(vararg advice: Advice?): EnricherSpec

afterPropertiesSet

open override fun afterPropertiesSet()

async

open fun async(async: Boolean): EnricherSpec

autoStartup

open override fun autoStartup(autoStartup: Boolean): EnricherSpec

customizeMonoReply

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

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

destroy

open override fun destroy()

errorChannel

fun errorChannel(errorChannel: String)

fun errorChannel(errorChannel: MessageChannel)

getComponentsToRegister

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

getObject

@NonNull

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

getObjectType

open override fun getObjectType(): Class<*>

getPhase

open override fun getPhase(): Int

handleMessageAdvice

open override fun handleMessageAdvice(vararg interceptors: MethodInterceptor?): EnricherSpec

header

fun header(headerName: String, headerValueMessageProcessor: HeaderValueMessageProcessor<Any>)

fun header(name: String, value: Any, overwrite: Boolean?)

headerExpression

fun headerExpression(name: String, expression: String, overwrite: Boolean?)

headerFunction

fun headerFunction(name: String, function: (Message) -> Any, overwrite: Boolean?)

open override fun id(id: String?): EnricherSpec

isAutoStartup

open override fun isAutoStartup(): Boolean

isRunning

open override fun isRunning(): Boolean

isSingleton

open fun isSingleton(): Boolean

notPropagatedHeaders

open fun notPropagatedHeaders(vararg headerPatterns: String): EnricherSpec

order

open fun order(order: Int): EnricherSpec

phase

open override fun phase(phase: Int): EnricherSpec

poller

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

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

open override fun poller(pollerMetadataSpec: PollerSpec): EnricherSpec

open override fun poller(pollerMetadata: PollerMetadata): EnricherSpec

property

fun property(key: String, value: Any)

propertyExpression

fun propertyExpression(key: String, expression: String)

propertyFunction

fun propertyFunction(key: String, function: (Message) -> Any)

reactive

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

open override fun reactive(): EnricherSpec

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

replyChannel

fun replyChannel(replyChannel: String)

fun replyChannel(replyChannel: MessageChannel)

replyTimeout

fun replyTimeout(replyTimeout: Long)

requestChannel

fun requestChannel(requestChannel: String)

fun requestChannel(requestChannel: MessageChannel)

requestPayload

fun requestPayload(function: (Message) -> Any)

requestPayloadExpression

fun requestPayloadExpression(requestPayloadExpression: String)

requestSubFlow

fun requestSubFlow(subFlow: KotlinIntegrationFlowDefinition.() -> Unit)

fun requestSubFlow(subFlow: IntegrationFlow)

requestTimeout

fun requestTimeout(requestTimeout: Long)

requiresReply

open fun requiresReply(requiresReply: Boolean): EnricherSpec

role

open override fun role(role: String): EnricherSpec

sendTimeout

open fun sendTimeout(sendTimeout: Long): EnricherSpec

shouldClonePayload

fun shouldClonePayload(shouldClonePayload: Boolean)

start

open override fun start()

stop

open override fun stop()

open override fun stop(callback: Runnable)

taskScheduler

open override fun taskScheduler(taskScheduler: TaskScheduler): EnricherSpec

transactional

open override fun transactional(): EnricherSpec

open override fun transactional(handleMessageAdvice: Boolean): EnricherSpec

open override fun transactional(transactionManager: TransactionManager): EnricherSpec

open override fun transactional(transactionInterceptor: TransactionInterceptor): EnricherSpec

open override fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean): EnricherSpec