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

KotlinEnricherSpec

class KotlinEnricherSpec : ConsumerEndpointSpec<EnricherSpec, ContentEnricher>

An EnricherSpec wrapped for Kotlin DSL.

Constructors

<init>

An EnricherSpec wrapped for Kotlin DSL.

KotlinEnricherSpec(delegate: EnricherSpec)

Properties

delegate

the EnricherSpec this instance is delegating to.

val delegate: EnricherSpec

Functions

errorChannel

fun errorChannel(errorChannel: MessageChannel): Unit
fun errorChannel(errorChannel: String): Unit

header

fun <V> header(name: String, value: V, overwrite: Boolean?): Unit
fun <V> header(headerName: String, headerValueMessageProcessor: HeaderValueMessageProcessor<V>): Unit

headerExpression

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

headerFunction

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

property

fun <V> property(key: String, value: V): Unit

propertyExpression

fun propertyExpression(key: String, expression: String): Unit

propertyFunction

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

replyChannel

fun replyChannel(replyChannel: MessageChannel): Unit
fun replyChannel(replyChannel: String): Unit

replyTimeout

fun replyTimeout(replyTimeout: Long): Unit

requestChannel

fun requestChannel(requestChannel: MessageChannel): Unit
fun requestChannel(requestChannel: String): Unit

requestPayload

fun <P> requestPayload(function: (Message<P>) -> Any): Unit

requestPayloadExpression

fun requestPayloadExpression(requestPayloadExpression: String): Unit

requestSubFlow

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

requestTimeout

fun requestTimeout(requestTimeout: Long): Unit

shouldClonePayload

fun shouldClonePayload(shouldClonePayload: Boolean): Unit