public class EnricherSpec extends ConsumerEndpointSpec<EnricherSpec,ContentEnricher>
| 修飾子と型 | フィールドと説明 |
|---|---|
protected MapSE<StringSE, HeaderValueMessageProcessor<?>> | headerExpressions |
protected MapSE<StringSE, Expression> | propertyExpressions |
adviceChaincomponentsToRegister, endpointFactoryBean, handlerPARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE| 修飾子 | コンストラクターと説明 |
|---|---|
protected | EnricherSpec() |
advice, async, autoStartup, customizeMonoReply, handleMessageAdvice, 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, setSingletoncloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEprotected final MapSE<StringSE,Expression> propertyExpressions
protected final MapSE<StringSE,HeaderValueMessageProcessor<?>> headerExpressions
public EnricherSpec requestChannel(MessageChannel requestChannel)
requestChannel - リクエストチャネル。ContentEnricher.setRequestChannel(MessageChannel)public EnricherSpec requestChannel(StringSE requestChannel)
requestChannel - リクエストチャネル。ContentEnricher.setRequestChannelName(String)public EnricherSpec replyChannel(MessageChannel replyChannel)
replyChannel - 返信チャネル。ContentEnricher.setReplyChannel(MessageChannel)public EnricherSpec replyChannel(StringSE replyChannel)
replyChannel - 返信チャネル。ContentEnricher.setReplyChannelName(String)public EnricherSpec errorChannel(MessageChannel errorChannel)
errorChannel - エラーチャネル。ContentEnricher.setErrorChannel(MessageChannel)public EnricherSpec errorChannel(StringSE errorChannel)
errorChannel - エラーチャネル Bean の名前。ContentEnricher.setErrorChannelName(String)public EnricherSpec requestTimeout(LongSE requestTimeout)
requestTimeout - requestTimeoutContentEnricher.setRequestTimeout(Long)public EnricherSpec replyTimeout(LongSE replyTimeout)
replyTimeout - replyTimeoutContentEnricher.setReplyTimeout(Long)public EnricherSpec requestPayloadExpression(StringSE requestPayloadExpression)
requestPayloadExpression - requestPayloadExpression。ContentEnricher.setRequestPayloadExpression(Expression)public <P> EnricherSpec requestPayload(java.util.function.FunctionSE<Message<P>,?> requestPayloadFunction)
P - ペイロード型。requestPayloadFunction - requestPayloadFunction。ContentEnricher.setRequestPayloadExpression(Expression), FunctionExpressionpublic EnricherSpec requestSubFlow(IntegrationFlow subFlow)
subFlow - subFlowDefinitionpublic EnricherSpec shouldClonePayload(boolean shouldClonePayload)
shouldClonePayload - shouldClonePayload。ContentEnricher.setShouldClonePayload(boolean)public <V> EnricherSpec property(StringSE key, V value)
V - 値の型。key - キー。value - 値。ContentEnricher.setPropertyExpressions(Map)public EnricherSpec propertyExpression(StringSE key, StringSE expression)
key - キー。expression - 表現。ContentEnricher.setPropertyExpressions(Map)public <P> EnricherSpec propertyFunction(StringSE key, java.util.function.FunctionSE<Message<P>,ObjectSE> function)
P - ペイロード型。key - キー。function - 関数(通常は JDK8 ラムダ)。ContentEnricher.setPropertyExpressions(Map), FunctionExpressionpublic <V> EnricherSpec header(StringSE name, V value)
V - 値の型。name - ヘッダー名。value - 値。ContentEnricher.setHeaderExpressions(Map)public <V> EnricherSpec header(StringSE name, V value, BooleanSE overwrite)
V - 値の型。name - ヘッダー名。value - 値。overwrite - すでに存在する場合、ヘッダーを上書きするには true。ContentEnricher.setHeaderExpressions(Map)public EnricherSpec headerExpression(StringSE name, StringSE expression)
name - ヘッダー名。expression - 値を取得するために応答メッセージに対して評価される式。ContentEnricher.setHeaderExpressions(Map)public EnricherSpec headerExpression(StringSE name, StringSE expression, BooleanSE overwrite)
name - ヘッダー名。expression - 値を取得するために応答メッセージに対して評価される式。overwrite - すでに存在する場合、ヘッダーを上書きするには true。ContentEnricher.setHeaderExpressions(Map)public <P> EnricherSpec headerFunction(StringSE name, java.util.function.FunctionSE<Message<P>,ObjectSE> function)
P - ペイロード型。name - ヘッダー名。function - 関数(通常は JDK8 ラムダ)。ContentEnricher.setHeaderExpressions(Map), FunctionExpressionpublic <P> EnricherSpec headerFunction(StringSE name, java.util.function.FunctionSE<Message<P>,ObjectSE> function, BooleanSE overwrite)
P - ペイロード型。name - ヘッダー名。function - 関数(通常は JDK8 ラムダ)。overwrite - すでに存在する場合、ヘッダーを上書きするには true。ContentEnricher.setHeaderExpressions(Map), FunctionExpressionpublic <V> EnricherSpec header(StringSE headerName, HeaderValueMessageProcessor<V> headerValueMessageProcessor)
HeaderValueMessageProcessor を使用してヘッダー値を設定します。V - 値の型。headerName - ヘッダー名。headerValueMessageProcessor - headerValueMessageProcessor。ContentEnricher.setHeaderExpressions(Map)protected reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,ContentEnricher> doGet()
ConsumerEndpointSpec<EnricherSpec, ContentEnricher> の doGet