public class EnricherSpec extends ConsumerEndpointSpec<EnricherSpec,ContentEnricher>
修飾子と型 | フィールドと説明 |
---|---|
protected MapSE<StringSE, HeaderValueMessageProcessor<?>> | headerExpressions |
protected MapSE<StringSE, Expression> | propertyExpressions |
adviceChain
componentsToRegister, endpointFactoryBean, handler
PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
修飾子 | コンストラクターと説明 |
---|---|
protected | EnricherSpec() |
advice, async, autoStartup, customizeMonoReply, handleMessageAdvice, notPropagatedHeaders, order, phase, poller, requiresReply, role, sendTimeout, taskScheduler, transactional, transactional, transactional, transactional, transactional
assertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller
_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
protected 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)
, FunctionExpression
public 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)
, FunctionExpression
public <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)
, FunctionExpression
public <P> EnricherSpec headerFunction(StringSE name, java.util.function.FunctionSE<Message<P>,ObjectSE> function, BooleanSE overwrite)
P
- ペイロード型。name
- ヘッダー名。function
- 関数(通常は JDK8 ラムダ)。overwrite
- すでに存在する場合、ヘッダーを上書きするには true。ContentEnricher.setHeaderExpressions(Map)
, FunctionExpression
public <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