public class EnricherSpec extends ConsumerEndpointSpec<EnricherSpec,ContentEnricher>
ConsumerEndpointSpec extension for the ContentEnricher.adviceChaincomponentsToRegister, endpointFactoryBean, handlerlogger, PARSER, targetDEFAULT_PHASEadvice, async, autoStartup, notPropagatedHeaders, order, phase, poller, requiresReply, role, sendTimeout, taskScheduler, transactional, transactional, transactional, transactional, transactionalassertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletonpublic EnricherSpec requestChannel(MessageChannel requestChannel)
requestChannel - the request channel.ContentEnricher.setRequestChannel(MessageChannel)public EnricherSpec requestChannel(String requestChannel)
requestChannel - the request channel.ContentEnricher.setRequestChannelName(String)public EnricherSpec replyChannel(MessageChannel replyChannel)
replyChannel - the reply channel.ContentEnricher.setReplyChannel(MessageChannel)public EnricherSpec replyChannel(String replyChannel)
replyChannel - the reply channel.ContentEnricher.setReplyChannelName(String)public EnricherSpec errorChannel(MessageChannel errorChannel)
errorChannel - the error channel.ContentEnricher.setErrorChannel(MessageChannel)public EnricherSpec errorChannel(String errorChannel)
errorChannel - the name of the error channel bean.ContentEnricher.setErrorChannelName(String)public EnricherSpec requestTimeout(Long requestTimeout)
requestTimeout - the requestTimeoutContentEnricher.setRequestTimeout(Long)public EnricherSpec replyTimeout(Long replyTimeout)
replyTimeout - the replyTimeoutContentEnricher.setReplyTimeout(Long)public EnricherSpec requestPayloadExpression(String requestPayloadExpression)
requestPayloadExpression - the requestPayloadExpression.ContentEnricher.setRequestPayloadExpression(Expression)public <P> EnricherSpec requestPayload(java.util.function.Function<Message<P>,?> requestPayloadFunction)
P - the payload type.requestPayloadFunction - the requestPayloadFunction.ContentEnricher.setRequestPayloadExpression(Expression),
FunctionExpressionpublic EnricherSpec requestSubFlow(IntegrationFlow subFlow)
subFlow - the subFlowDefinitionpublic EnricherSpec shouldClonePayload(boolean shouldClonePayload)
shouldClonePayload - the shouldClonePayload.ContentEnricher.setShouldClonePayload(boolean)public <V> EnricherSpec property(String key, V value)
V - the value type.key - the key.value - the value.ContentEnricher.setPropertyExpressions(Map)public EnricherSpec propertyExpression(String key, String expression)
key - the key.expression - the expression.ContentEnricher.setPropertyExpressions(Map)public <P> EnricherSpec propertyFunction(String key, java.util.function.Function<Message<P>,Object> function)
P - the payload type.key - the key.function - the function (usually a JDK8 lambda).ContentEnricher.setPropertyExpressions(Map),
FunctionExpressionpublic <V> EnricherSpec header(String name, V value)
V - the value type.name - the header name.value - the value.ContentEnricher.setHeaderExpressions(Map)public <V> EnricherSpec header(String name, V value, Boolean overwrite)
V - the value type.name - the header name.value - the value.overwrite - true to overwrite the header if already present.ContentEnricher.setHeaderExpressions(Map)public EnricherSpec headerExpression(String name, String expression)
name - the header name.expression - the expression to be evaluated against the reply message to obtain the value.ContentEnricher.setHeaderExpressions(Map)public EnricherSpec headerExpression(String name, String expression, Boolean overwrite)
name - the header name.expression - the expression to be evaluated against the reply message to obtain the value.overwrite - true to overwrite the header if already present.ContentEnricher.setHeaderExpressions(Map)public <P> EnricherSpec headerFunction(String name, java.util.function.Function<Message<P>,Object> function)
P - the payload type.name - the header name.function - the function (usually a JDK8 lambda).ContentEnricher.setHeaderExpressions(Map),
FunctionExpressionpublic <P> EnricherSpec headerFunction(String name, java.util.function.Function<Message<P>,Object> function, Boolean overwrite)
P - the payload type.name - the header name.function - the function (usually a JDK8 lambda).overwrite - true to overwrite the header if already present.ContentEnricher.setHeaderExpressions(Map),
FunctionExpressionpublic <V> EnricherSpec header(String headerName, HeaderValueMessageProcessor<V> headerValueMessageProcessor)
HeaderValueMessageProcessor.V - the value type.headerName - the header name.headerValueMessageProcessor - the headerValueMessageProcessor.ContentEnricher.setHeaderExpressions(Map)protected reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,ContentEnricher> doGet()
doGet in class ConsumerEndpointSpec<EnricherSpec,ContentEnricher>