class KotlinEnricherSpec : ConsumerEndpointSpec<EnricherSpec, ContentEnricher>
An EnricherSpec wrapped for Kotlin DSL.
<init> |
An EnricherSpec wrapped for Kotlin DSL. KotlinEnricherSpec(delegate: EnricherSpec) |
delegate |
the EnricherSpec this instance is delegating to. val delegate: EnricherSpec |
errorChannel |
fun errorChannel(errorChannel: MessageChannel): Unitfun errorChannel(errorChannel: String): Unit |
header |
fun <V> header(name: String, value: V, overwrite: Boolean?): Unitfun <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): Unitfun replyChannel(replyChannel: String): Unit |
replyTimeout |
fun replyTimeout(replyTimeout: Long): Unit |
requestChannel |
fun requestChannel(requestChannel: MessageChannel): Unitfun 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 |