org.springframework.integration.aggregator.ResequencingMessageHandler

実装済みのインターフェース一覧:: org.reactivestreams.Subscriber<Message<?>>、Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、ApplicationEventPublisherAware、Lifecycle、Ordered、ComponentSourceAware、ExpressionCapable、Orderable、MessageProducer、DiscardingMessageHandler、HeaderPropagationAware、IntegrationPattern、NamedComponent、IntegrationManagement、ManageableLifecycle、TrackableComponent、MessageHandler、reactor.core.CoreSubscriber<Message<?>>

public class ResequencingMessageHandler extends AbstractCorrelatingMessageHandler

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 と等しい場合は、グループの削除を実行します。
StringSE
getComponentType()
サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
IntegrationPatternType
getIntegrationPatternType()
このコンポーネントが実装するパターン型を返します。
final void
setExpireGroupsUponTimeout(boolean expireGroupsUponTimeout)
リシーケンサーの場合は false にオーバーライドされるため、遅延メッセージは次のタイムアウトを待つのではなく、すぐに破棄されます。
protected boolean
shouldCopyRequestHeaders()
サブクラスはこれをオーバーライドできます。
クラス 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, setDiscardIndividuallyOnExpiry, 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, getComponentDescription, getComponentName, getComponentSource, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, 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
  public ResequencingMessageHandler(MessageGroupProcessor processor, MessageGroupStore store)
- ResequencingMessageHandler
  public ResequencingMessageHandler(MessageGroupProcessor processor)
方法の詳細
- setExpireGroupsUponTimeout
  public final void setExpireGroupsUponTimeout(boolean expireGroupsUponTimeout)
  リシーケンサーの場合は false にオーバーライドされるため、遅延メッセージは次のタイムアウトを待つのではなく、すぐに破棄されます。
  オーバーライド:
  クラス AbstractCorrelatingMessageHandler の setExpireGroupsUponTimeout
  パラメーター:
  expireGroupsUponTimeout - 設定する expireGroupsUponTimeout
- getComponentType
  public StringSE getComponentType()
  クラスからコピーされた説明: IntegrationObjectSupport
  サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
  次で指定:
  インターフェース NamedComponent 内の getComponentType
  オーバーライド:
  クラス AbstractCorrelatingMessageHandler の getComponentType
- getIntegrationPatternType
  public IntegrationPatternType getIntegrationPatternType()
  インターフェースからコピーされた説明: IntegrationPattern
  このコンポーネントが実装するパターン型を返します。
  次で指定:
  インターフェース IntegrationPattern 内の getIntegrationPatternType
  オーバーライド:
  クラス MessageHandlerSupport の getIntegrationPatternType
  戻り値:
  このコンポーネントが実装する IntegrationPatternType
- shouldCopyRequestHeaders
  protected boolean shouldCopyRequestHeaders()
  クラスからコピーされた説明: AbstractMessageProducingHandler
  サブクラスはこれをオーバーライドできます。デフォルトでは true。
  オーバーライド:
  クラス AbstractMessageProducingHandler の shouldCopyRequestHeaders
  戻り値:
  リクエストヘッダーをコピーする必要がある場合は true。
- afterRelease
  protected void afterRelease(MessageGroup messageGroup, CollectionSE<Message<?>> completedMessages)
  クラスからコピーされた説明: 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。

クラス ResequencingMessageHandler

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

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

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

フィールド概要

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

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

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

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

コンストラクター概要

方法の概要

クラス 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 から継承されたメソッド

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

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

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

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

コンストラクターの詳細

ResequencingMessageHandler

ResequencingMessageHandler

ResequencingMessageHandler

方法の詳細

setExpireGroupsUponTimeout

getComponentType

getIntegrationPatternType

shouldCopyRequestHeaders

afterRelease

afterRelease