クラス AggregatorSpec
java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec < AggregatorSpec、reacters.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
フィールドのサマリー
クラス org.springframework.integration.dsl.ConsumerEndpointSpec から継承されたフィールド
adviceChainクラス org.springframework.integration.dsl.EndpointSpec から継承されたフィールド
componentsToRegister, endpointFactoryBean, handlerクラス org.springframework.integration.dsl.IntegrationComponentSpec から継承されたフィールド
logger, PARSER, targetインターフェース org.springframework.beans.factory.FactoryBean から継承されたフィールド
OBJECT_TYPE_ATTRIBUTEインターフェース org.springframework.context.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でハンドラーを構成します。クラス org.springframework.integration.dsl.CorrelationHandlerSpec から継承されたメソッド
correlationExpression, correlationStrategy, correlationStrategy, discardChannel, discardChannel, expireDuration, expireGroupsUponTimeout, expireTimeout, forceReleaseAdvice, groupConditionSupplier, groupTimeout, groupTimeout, groupTimeoutExpression, lockRegistry, messageStore, minimumTimeoutForEmptyGroups, popSequence, releaseExpression, releaseLockBeforeSend, releaseStrategy, releaseStrategy, sendPartialResultOnExpiry, taskSchedulerクラス org.springframework.integration.dsl.ConsumerEndpointSpec から継承されたメソッド
advice, async, autoStartup, customizeMonoReply, doGet, handleMessageAdvice, notPropagatedHeaders, order, phase, poller, reactive, reactive, requiresReply, role, sendTimeout, transactional, transactional, transactional, transactional, transactionalクラス org.springframework.integration.dsl.EndpointSpec から継承されたメソッド
assertHandler, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, pollerクラス org.springframework.integration.dsl.IntegrationComponentSpec から継承されたメソッド
_this, afterPropertiesSet, destroy, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopクラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース org.springframework.beans.factory.FactoryBean から継承されたメソッド
isSingleton
コンストラクターの詳細
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