クラス AggregatingMessageHandler
java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.handler.AbstractMessageProducingHandler
org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler
org.springframework.integration.aggregator.AggregatingMessageHandler
- 実装されたすべてのインターフェース:
org.reactivestreams.Subscriber<Message<?>>
、Aware
、BeanFactoryAware
、BeanNameAware
、DisposableBean
、InitializingBean
、ApplicationContextAware
、ApplicationEventPublisherAware
、Lifecycle
、Ordered
、ExpressionCapable
、Orderable
、MessageProducer
、DiscardingMessageHandler
、HeaderPropagationAware
、IntegrationPattern
、NamedComponent
、IntegrationManagement
、ManageableLifecycle
、TrackableComponent
、MessageHandler
、reactor.core.CoreSubscriber<Message<?>>
AbstractCorrelatingMessageHandler
のアグリゲーター固有の実装。'expireGroupsUponCompletion' フラグが 'true' に設定されている場合にのみ、afterRelease(org.springframework.integration.store.MessageGroup, java.util.Collection<org.springframework.messaging.Message<?>>) 内の MessageGroup
を削除します。- 導入:
- 2.1
- 作成者:
- Oleg Zhurakousky, Artem Bilan, Gary Russell
ネストされたクラスのサマリー
クラス org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler から継承されたネストクラス / インターフェース
AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverrides
フィールドサマリー
クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたフィールド
messagingTemplate
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, logger
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
インターフェース org.springframework.core.Ordered から継承されたフィールド
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
コンストラクターのサマリー
コンストラクター説明AggregatingMessageHandler
(MessageGroupProcessor processor) AggregatingMessageHandler
(MessageGroupProcessor processor, MessageGroupStore store) AggregatingMessageHandler
(MessageGroupProcessor processor, MessageGroupStore store, CorrelationStrategy correlationStrategy, ReleaseStrategy releaseStrategy) メソッドのサマリー
修飾子と型メソッド説明protected void
afterRelease
(MessageGroup messageGroup, CollectionSE<Message<?>> completedMessages) グループを完成させ、そのメッセージをすべて削除します。このコンポーネントが実装するパターン型を返します。protected boolean
void
setExpireGroupsUponCompletion
(boolean expireGroupsUponCompletion) 'expireGroupsUponCompletion' フラグを設定します。protected boolean
shouldSplitOutput
(IterableSE<?> reply) 出力本番での分割の可能性についてIterable
SE の結果を確認してください。コレクションのアイテムはMessage
またはAbstractIntegrationMessageBuilder
のインスタンスである必要があり、AbstractCorrelatingMessageHandler.getOutputProcessor()
はSimpleMessageGroupProcessor
である必要があります。クラス org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler から継承されたメソッド
afterRelease, completeGroup, completeGroup, destroy, expireGroup, findLastReleasedSequenceNumber, forceComplete, getComponentType, getCorrelationStrategy, getDiscardChannel, getDiscardChannelName, getEvaluationContext, getExpireGroupScheduledFutures, getGroupConditionSupplier, getGroupTimeoutExpression, getLockRegistry, getMessageStore, getMinimumTimeoutForEmptyGroups, getOutputProcessor, getReleaseStrategy, handleMessageInternal, isLockRegistrySet, isReleaseLockBeforeSend, isReleasePartialSequences, isRunning, isSendPartialResultOnExpiry, isSequenceAware, obtainGroupTimeout, onInit, purgeOrphanedGroups, remove, setApplicationEventPublisher, setCorrelationStrategy, setDiscardChannel, setDiscardChannelName, setExpireDuration, setExpireDurationMillis, setExpireGroupsUponTimeout, setExpireTimeout, setForceReleaseAdviceChain, setGroupConditionSupplier, setGroupTimeoutExpression, setLockRegistry, setMessageStore, setMinimumTimeoutForEmptyGroups, setOutputProcessor, setPopSequence, setReleaseLockBeforeSend, setReleasePartialSequences, setReleaseStrategy, setSendPartialResultOnExpiry, start, stop, store, verifyResultCollectionConsistsOfMessages
クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたメソッド
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, setupMessageProcessor, shouldCopyRequestHeaders, updateNotPropagatedHeaders
クラス org.springframework.integration.handler.AbstractMessageHandler から継承されたメソッド
handleMessage, onComplete, onError, onNext, onSubscribe, setObservationConvention
クラス org.springframework.integration.handler.MessageHandlerSupport から継承されたメソッド
buildSendTimer, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSE
インターフェース reactor.core.CoreSubscriber から継承されたメソッド
currentContext
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getThisAs
インターフェース org.springframework.messaging.MessageHandler から継承されたメソッド
handleMessage
インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName
コンストラクターの詳細
AggregatingMessageHandler
public AggregatingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store, CorrelationStrategy correlationStrategy, ReleaseStrategy releaseStrategy) AggregatingMessageHandler
AggregatingMessageHandler
メソッドの詳細
setExpireGroupsUponCompletion
public void setExpireGroupsUponCompletion(boolean expireGroupsUponCompletion) 'expireGroupsUponCompletion' フラグを設定します。- パラメーター:
expireGroupsUponCompletion
- グループが完了時に期限切れになる必要がある場合は true。- 関連事項:
getIntegrationPatternType
インターフェースからコピーされた説明:IntegrationPattern
このコンポーネントが実装するパターン型を返します。- 次で指定:
- インターフェース
IntegrationPattern
のgetIntegrationPatternType
- オーバーライド:
- クラス
MessageHandlerSupport
のgetIntegrationPatternType
- 戻り値:
- このコンポーネントが実装する
IntegrationPatternType
isExpireGroupsUponCompletion
protected boolean isExpireGroupsUponCompletion()- オーバーライド:
- クラス
AbstractCorrelatingMessageHandler
のisExpireGroupsUponCompletion
shouldSplitOutput
出力本番での分割の可能性についてIterable
SE の結果を確認してください。コレクションのアイテムはMessage
またはAbstractIntegrationMessageBuilder
のインスタンスである必要があり、AbstractCorrelatingMessageHandler.getOutputProcessor()
はSimpleMessageGroupProcessor
である必要があります。それ以外の場合は、Iterable
SE 全体をペイロードとして単一の応答メッセージが送信されます。- オーバーライド:
- クラス
AbstractMessageProducingHandler
のshouldSplitOutput
- パラメーター:
reply
- 分割の可能性をチェックするためのIterable
SE 結果。- 戻り値:
Iterable
SE の結果を個々のメッセージに分割する必要がある場合は true。- 導入:
- 6.0
afterRelease
グループを完成させ、そのメッセージをすべて削除します。expireGroupsUponCompletion
が true の場合は、グループを完全に削除します。- 次で指定:
- クラス
AbstractCorrelatingMessageHandler
のafterRelease
- パラメーター:
messageGroup
- クリーンアップするグループ。completedMessages
- 完成したメッセージ。この実装では無視されます。