クラス ResequencingMessageHandler
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.ResequencingMessageHandler
- 実装されたすべてのインターフェース:
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
のリシーケンサー固有の実装。'sequenceSize' が指定されて到達した場合にのみ、MessageGroup
を削除します。- 導入:
- 2.1
- 作成者:
- Oleg Zhurakousky, Gary Russell, Artem Bilan
ネストされたクラスのサマリー
クラス 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
コンストラクターのサマリー
コンストラクターコンストラクター説明ResequencingMessageHandler
(MessageGroupProcessor processor) ResequencingMessageHandler
(MessageGroupProcessor processor, MessageGroupStore store) ResequencingMessageHandler
(MessageGroupProcessor processor, MessageGroupStore store, CorrelationStrategy correlationStrategy, ReleaseStrategy releaseStrategy) メソッドのサマリー
修飾子と型メソッド説明protected void
afterRelease
(MessageGroup messageGroup, CollectionSE<Message<?>> completedMessages) MessageGroup のリリース後に実行する必要がある追加のロジックを提供できます。protected void
afterRelease
(MessageGroup messageGroup, CollectionSE<Message<?>> completedMessages, boolean timeout) size
がsequenceSize
と等しい場合は、グループの削除を実行します。サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。このコンポーネントが実装するパターン型を返します。final void
setExpireGroupsUponTimeout
(boolean expireGroupsUponTimeout) リシーケンサーの場合は false にオーバーライドされるため、遅延メッセージは次のタイムアウトを待つのではなく、すぐに破棄されます。protected boolean
サブクラスはこれをオーバーライドできます。クラス org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler から継承されたメソッド
completeGroup, completeGroup, destroy, expireGroup, findLastReleasedSequenceNumber, forceComplete, getCorrelationStrategy, getDiscardChannel, getDiscardChannelName, getEvaluationContext, getExpireGroupScheduledFutures, getGroupConditionSupplier, getGroupTimeoutExpression, getLockRegistry, getMessageStore, getMinimumTimeoutForEmptyGroups, getOutputProcessor, getReleaseStrategy, handleMessageInternal, isExpireGroupsUponCompletion, isLockRegistrySet, isReleaseLockBeforeSend, isReleasePartialSequences, isRunning, isSendPartialResultOnExpiry, isSequenceAware, obtainGroupTimeout, onInit, purgeOrphanedGroups, remove, setApplicationEventPublisher, setCorrelationStrategy, setDiscardChannel, setDiscardChannelName, setExpireDuration, setExpireDurationMillis, 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, shouldSplitOutput, 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
コンストラクターの詳細
ResequencingMessageHandler
public ResequencingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store, CorrelationStrategy correlationStrategy, ReleaseStrategy releaseStrategy) ResequencingMessageHandler
ResequencingMessageHandler
メソッドの詳細
setExpireGroupsUponTimeout
public final void setExpireGroupsUponTimeout(boolean expireGroupsUponTimeout) リシーケンサーの場合は false にオーバーライドされるため、遅延メッセージは次のタイムアウトを待つのではなく、すぐに破棄されます。- オーバーライド:
- クラス
AbstractCorrelatingMessageHandler
のsetExpireGroupsUponTimeout
- パラメーター:
expireGroupsUponTimeout
- 設定する expireGroupsUponTimeout
getComponentType
クラスからコピーされた説明:IntegrationObjectSupport
サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。- 次で指定:
- インターフェース
NamedComponent
のgetComponentType
- オーバーライド:
- クラス
AbstractCorrelatingMessageHandler
のgetComponentType
getIntegrationPatternType
インターフェースからコピーされた説明:IntegrationPattern
このコンポーネントが実装するパターン型を返します。- 次で指定:
- インターフェース
IntegrationPattern
のgetIntegrationPatternType
- オーバーライド:
- クラス
MessageHandlerSupport
のgetIntegrationPatternType
- 戻り値:
- このコンポーネントが実装する
IntegrationPatternType
shouldCopyRequestHeaders
protected boolean shouldCopyRequestHeaders()クラスからコピーされた説明:AbstractMessageProducingHandler
サブクラスはこれをオーバーライドできます。デフォルトでは true。- オーバーライド:
- クラス
AbstractMessageProducingHandler
のshouldCopyRequestHeaders
- 戻り値:
- リクエストヘッダーをコピーする必要がある場合は true。
afterRelease
クラスからコピーされた説明:AbstractCorrelatingMessageHandler
MessageGroup のリリース後に実行する必要がある追加のロジックを提供できます。- 次で指定:
- クラス
AbstractCorrelatingMessageHandler
のafterRelease
- パラメーター:
messageGroup
- グループ。completedMessages
- 完了したメッセージ。
afterRelease
protected void afterRelease(MessageGroup messageGroup, CollectionSE<Message<?>> completedMessages, boolean timeout) size
がsequenceSize
と等しい場合は、グループの削除を実行します。null でない場合は、completedMessages
をグループから削除します。- オーバーライド:
- クラス
AbstractCorrelatingMessageHandler
のafterRelease
- パラメーター:
messageGroup
- クリーンアップするグループ。completedMessages
- 完了したメッセージ。timeout
- リリースまたは破棄がタイムアウトによるものである場合は true。