AggregatingMessageHandler (Spring Integration API)

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<?>>
```
public class AggregatingMessageHandler
extends AbstractCorrelatingMessageHandler
```
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.core.Ordered から継承されたフィールド
  HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
- インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
  METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

コンストラクター概要

コンストラクター
コンストラクターと説明
`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)` グループを完成させ、そのメッセージをすべて削除します。
`IntegrationPatternType`	`getIntegrationPatternType()` このコンポーネントが実装するパターン型を返します。
`protected boolean`	`isExpireGroupsUponCompletion()`
`void`	`setExpireGroupsUponCompletion(boolean expireGroupsUponCompletion)` "expireGroupsUponCompletion" フラグを設定します。

クラス org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler から継承されたメソッド
afterRelease, completeGroup, completeGroup, destroy, expireGroup, findLastReleasedSequenceNumber, forceComplete, getComponentType, getCorrelationStrategy, getDiscardChannel, getDiscardChannelName, getEvaluationContext, getExpireGroupScheduledFutures, 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, 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, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders

クラス org.springframework.integration.handler.AbstractMessageHandler から継承されたメソッド
handleMessage, onComplete, onError, onNext, onSubscribe

クラス org.springframework.integration.handler.MessageHandlerSupport から継承されたメソッド
buildSendTimer, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, 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, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

クラス java.lang.ObjectSE から継承されたメソッド
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE

インターフェース org.springframework.messaging.MessageHandler から継承されたメソッド
handleMessage

インターフェース reactor.core.CoreSubscriber から継承されたメソッド
currentContext

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getThisAs

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName

- コンストラクターの詳細
  - AggregatingMessageHandler
```
public AggregatingMessageHandler(MessageGroupProcessor processor,
                                 MessageGroupStore store,
                                 CorrelationStrategy correlationStrategy,
                                 ReleaseStrategy releaseStrategy)
```
  - AggregatingMessageHandler
```
public AggregatingMessageHandler(MessageGroupProcessor processor,
                                 MessageGroupStore store)
```
  - AggregatingMessageHandler
```
public AggregatingMessageHandler(MessageGroupProcessor processor)
```
- メソッドの詳細
  - setExpireGroupsUponCompletion
```
public void setExpireGroupsUponCompletion(boolean expireGroupsUponCompletion)
```
    "expireGroupsUponCompletion" フラグを設定します。
    パラメーター:
    expireGroupsUponCompletion - グループが完了時に期限切れになる必要がある場合は true。
    関連事項:
    afterRelease(org.springframework.integration.store.MessageGroup, java.util.Collection<org.springframework.messaging.Message<?>>)
  - getIntegrationPatternType
```
public IntegrationPatternType getIntegrationPatternType()
```
    インターフェースからコピーされた説明: IntegrationPattern
    このコンポーネントが実装するパターン型を返します。
    次で指定:
    インターフェース IntegrationPattern 内の getIntegrationPatternType
    オーバーライド:
    クラス MessageHandlerSupport の getIntegrationPatternType
    戻り値:
    このコンポーネントが実装する IntegrationPatternType
  - isExpireGroupsUponCompletion
```
protected boolean isExpireGroupsUponCompletion()
```
    オーバーライド:
    クラス AbstractCorrelatingMessageHandler の isExpireGroupsUponCompletion
  - afterRelease
```
protected void afterRelease(MessageGroup messageGroup,
                            CollectionSE<Message<?>> completedMessages)
```
    グループを完成させ、そのメッセージをすべて削除します。expireGroupsUponCompletion が真の場合は、グループを完全に削除します。
    次で指定:
    クラス AbstractCorrelatingMessageHandler の afterRelease
    パラメーター:
    messageGroup - クリーンアップするグループ。
    completedMessages - 完成したメッセージ。この実装では無視されます。

クラス AggregatingMessageHandler

ネストされたクラスの概要

クラス org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler から継承されたネストクラス / インターフェース

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース

フィールド概要

クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたフィールド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド

インターフェース org.springframework.core.Ordered から継承されたフィールド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド

コンストラクター概要

方法の概要

クラス org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler から継承されたメソッド

クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたメソッド

クラス org.springframework.integration.handler.AbstractMessageHandler から継承されたメソッド

クラス org.springframework.integration.handler.MessageHandlerSupport から継承されたメソッド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド

クラス java.lang.ObjectSE から継承されたメソッド

インターフェース org.springframework.messaging.MessageHandler から継承されたメソッド

インターフェース reactor.core.CoreSubscriber から継承されたメソッド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド

コンストラクターの詳細

AggregatingMessageHandler

AggregatingMessageHandler

AggregatingMessageHandler

メソッドの詳細

setExpireGroupsUponCompletion

getIntegrationPatternType

isExpireGroupsUponCompletion

afterRelease