クラス AggregatorSpec
java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<AggregatorSpec, reactor.util.function.Tuple2<ConsumerEndpointFactoryBean, AggregatingMessageHandler>>
org.springframework.integration.dsl.EndpointSpec<AggregatorSpec, ConsumerEndpointFactoryBean, AggregatingMessageHandler>
org.springframework.integration.dsl.ConsumerEndpointSpec<AggregatorSpec, AggregatingMessageHandler>
org.springframework.integration.dsl.CorrelationHandlerSpec<AggregatorSpec, AggregatingMessageHandler>
org.springframework.integration.dsl.AggregatorSpec
- 実装済みのインターフェース一覧:
DisposableBean, FactoryBean<reactor.util.function.Tuple2<ConsumerEndpointFactoryBean, AggregatingMessageHandler>>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration
public class AggregatorSpec
extends CorrelationHandlerSpec<AggregatorSpec, AggregatingMessageHandler>
- 導入:
- 5.0
- 作成者:
- Artem Bilan, Ngoc Nhan
フィールド概要
クラス ConsumerEndpointSpec から継承されたフィールド
adviceChainクラス EndpointSpec から継承されたフィールド
componentsToRegister, endpointFactoryBean, handlerクラス IntegrationComponentSpec から継承されたフィールド
logger, PARSER, targetインターフェース FactoryBean から継承されたフィールド
OBJECT_TYPE_ATTRIBUTEインターフェース SmartLifecycle から継承されたフィールド
DEFAULT_PHASEコンストラクター概要
コンストラクター方法の概要
修飾子と型メソッド説明expireGroupsUponCompletion(boolean expireGroupsUponCompletion) headersFunction(FunctionSE<MessageGroup, MapSE<StringSE, ObjectSE>> headersFunction) 完成したMessageGroupに基づいて応答用のヘッダーをマージおよび計算するようにFunctionSE を構成します。outputExpression(StringSE expression) 解放されたグループからの出力メッセージを決定する式。outputProcessor(MessageGroupProcessor outputProcessor) 解放されたグループからの出力メッセージを判別するプロセッサー。各関数に適切にアノテーションが付けられたメソッドを持つ必要があるターゲットオブジェクトを使用して、MethodInvokingCorrelationStrategyおよびMethodInvokingReleaseStrategyでハンドラーを構成します。各関数に適切にアノテーションが付けられたメソッドを持つ必要があるターゲットオブジェクトを使用して、MethodInvokingCorrelationStrategyおよびMethodInvokingReleaseStrategyでハンドラーを構成します。クラス CorrelationHandlerSpec から継承されたメソッド
correlationExpression, correlationStrategy, correlationStrategy, discardChannel, discardChannel, discardIndividuallyOnExpiry, expireDuration, expireGroupsUponTimeout, expireTimeout, forceReleaseAdvice, groupConditionSupplier, groupTimeout, groupTimeout, groupTimeoutExpression, lockRegistry, messageStore, minimumTimeoutForEmptyGroups, popSequence, releaseExpression, releaseLockBeforeSend, releaseStrategy, releaseStrategy, sendPartialResultOnExpiry, taskSchedulerクラス ConsumerEndpointSpec から継承されたメソッド
advice, async, autoStartup, customizeMonoReply, doGet, handleMessageAdvice, notPropagatedHeaders, order, phase, poller, reactive, reactive, requiresReply, role, sendTimeout, transactional, transactional, transactional, transactional, transactionalクラス EndpointSpec から継承されたメソッド
id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, pollerクラス IntegrationComponentSpec から継承されたメソッド
_this, afterPropertiesSet, destroy, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopクラス ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース FactoryBean から継承されたメソッド
isSingletonインターフェース SmartLifecycle から継承されたメソッド
isPauseable
コンストラクターの詳細
AggregatorSpec
protected AggregatorSpec()
方法の詳細
processor
各関数に適切にアノテーションが付けられたメソッドを持つ必要があるターゲットオブジェクトを使用して、MethodInvokingCorrelationStrategyおよびMethodInvokingReleaseStrategyでハンドラーを構成します。また、出力プロセッサーを設定します。- オーバーライド:
- クラス
CorrelationHandlerSpec<AggregatorSpec, AggregatingMessageHandler>のprocessor - パラメーター:
target- ターゲットオブジェクト。- 戻り値:
- ハンドラーの仕様。
- 関連事項:
processor
各関数に適切にアノテーションが付けられたメソッドを持つ必要があるターゲットオブジェクトを使用して、MethodInvokingCorrelationStrategyおよびMethodInvokingReleaseStrategyでハンドラーを構成します。また、出力プロセッサーを設定します。- パラメーター:
target- ターゲットオブジェクト。methodName- 出力プロセッサーのメソッド名（または "null" の場合、ターゲットオブジェクトにはAggregatorアノテーションが必要です）。- 戻り値:
- ハンドラーの仕様。
outputExpression
解放されたグループからの出力メッセージを決定する式。デフォルトでは、入力メッセージからのペイロードのコレクションであるペイロードを持つメッセージになります。- パラメーター:
expression- 表現。- 戻り値:
- アグリゲーターの仕様。
outputProcessor
解放されたグループからの出力メッセージを判別するプロセッサー。デフォルトでは、入力メッセージからのペイロードのコレクションであるペイロードを持つメッセージになります。- パラメーター:
outputProcessor- プロセッサー。- 戻り値:
- アグリゲーターの仕様。
expireGroupsUponCompletion
- パラメーター:
expireGroupsUponCompletion- expireGroupsUponCompletion。- 戻り値:
- アグリゲーターの仕様。
- 関連事項:
headersFunction
public AggregatorSpec headersFunction(FunctionSE<MessageGroup, MapSE<StringSE, ObjectSE>> headersFunction) 完成したMessageGroupに基づいて応答用のヘッダーをマージおよび計算するようにFunctionSE を構成します。- パラメーター:
headersFunction- 完成したMessageGroupに基づいて応答用のヘッダーをマージおよび計算するFunctionSE。- 戻り値:
- アグリゲーターの仕様。
- 導入:
- 5.2
getComponentsToRegister
- 次で指定:
- インターフェース
ComponentsRegistration内のgetComponentsToRegister - オーバーライド:
- クラス
EndpointSpec<AggregatorSpec, ConsumerEndpointFactoryBean, AggregatingMessageHandler>のgetComponentsToRegister