public class AggregatorSpec extends CorrelationHandlerSpec<AggregatorSpec,AggregatingMessageHandler>
adviceChain
componentsToRegister, endpointFactoryBean, handler
PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
修飾子 | コンストラクターと説明 |
---|---|
protected | AggregatorSpec() |
修飾子と型 | メソッドと説明 |
---|---|
AggregatorSpec | expireGroupsUponCompletion(boolean expireGroupsUponCompletion) |
MapSE<ObjectSE, StringSE> | getComponentsToRegister() |
AggregatorSpec | headersFunction(java.util.function.FunctionSE<MessageGroup, MapSE<StringSE, ObjectSE>> headersFunction) 完成した MessageGroup に基づいて応答用のヘッダーをマージおよび計算するように Function SE を構成します。 |
AggregatorSpec | outputExpression(StringSE expression) 解放されたグループからの出力メッセージを決定する式。 |
AggregatorSpec | outputProcessor(MessageGroupProcessor outputProcessor) 解放されたグループからの出力メッセージを判別するプロセッサー。 |
AggregatorSpec | processor(ObjectSE target) 各関数に適切にアノテーションが付けられたメソッドを持つ必要があるターゲットオブジェクトを使用して、 MethodInvokingCorrelationStrategy および MethodInvokingReleaseStrategy でハンドラーを構成します。 |
AggregatorSpec | processor(ObjectSE target, StringSE methodName) 各関数に適切にアノテーションが付けられたメソッドを持つ必要があるターゲットオブジェクトを使用して、 MethodInvokingCorrelationStrategy および MethodInvokingReleaseStrategy でハンドラーを構成します。 |
correlationExpression, correlationStrategy, correlationStrategy, discardChannel, discardChannel, expireGroupsUponTimeout, forceReleaseAdvice, groupTimeout, groupTimeout, groupTimeoutExpression, lockRegistry, messageStore, minimumTimeoutForEmptyGroups, popSequence, releaseExpression, releaseStrategy, releaseStrategy, sendPartialResultOnExpiry, setExpireDuration, setExpireTimeout, taskScheduler
advice, async, autoStartup, customizeMonoReply, doGet, handleMessageAdvice, notPropagatedHeaders, order, phase, poller, requiresReply, role, sendTimeout, transactional, transactional, transactional, transactional, transactional
assertHandler, 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
public AggregatorSpec processor(ObjectSE target)
MethodInvokingCorrelationStrategy
および MethodInvokingReleaseStrategy
でハンドラーを構成します。また、出力プロセッサーを設定します。CorrelationHandlerSpec<AggregatorSpec, AggregatingMessageHandler>
の processor
target
- ターゲットオブジェクト。AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy)
, AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)
public AggregatorSpec processor(ObjectSE target, StringSE methodName)
MethodInvokingCorrelationStrategy
および MethodInvokingReleaseStrategy
でハンドラーを構成します。また、出力プロセッサーを設定します。target
- ターゲットオブジェクト。methodName
- 出力プロセッサーのメソッド名(または "null" の場合、ターゲットオブジェクトには Aggregator
アノテーションが必要です)。public AggregatorSpec outputExpression(StringSE expression)
expression
- 表現。public AggregatorSpec outputProcessor(MessageGroupProcessor outputProcessor)
outputProcessor
- プロセッサー。public AggregatorSpec expireGroupsUponCompletion(boolean expireGroupsUponCompletion)
expireGroupsUponCompletion
- expireGroupsUponCompletion。AggregatingMessageHandler.setExpireGroupsUponCompletion(boolean)
public AggregatorSpec headersFunction(java.util.function.FunctionSE<MessageGroup,MapSE<StringSE,ObjectSE>> headersFunction)
MessageGroup
に基づいて応答用のヘッダーをマージおよび計算するように Function
SE を構成します。headersFunction
- 完成した MessageGroup
に基づいて応答用のヘッダーをマージおよび計算する Function
SE。public MapSE<ObjectSE,StringSE> getComponentsToRegister()
ComponentsRegistration
の getComponentsToRegister
EndpointSpec<AggregatorSpec, ConsumerEndpointFactoryBean, AggregatingMessageHandler>
の getComponentsToRegister