クラス 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
フィールドのサマリー
クラス 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, discardIndividuallyOnExpiry, 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 から継承されたメソッド
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インターフェース org.springframework.context.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