インターフェースの使用
org.springframework.integration.store.MessageGroup
MessageGroup を使用するパッケージ
パッケージ
説明
メッセージ集約に関連するクラスを提供します。
構成の基本パッケージ。
Spring Integration Java DSL のルートパッケージ。
ファイルベースの集約ロジックのサポートクラスを提供します。
JDBC を使用したメッセージストアの実装を提供します。
MongoDB メッセージストアに関連するクラスを提供します。
Redis メッセージストアに関連するクラスを提供します。
メッセージの保存に関連するクラスを提供します。
org.springframework.integration.aggregator 内の MessageGroup 使用
MessageGroup を実装している org.springframework.integration.aggregator のクラスMessageGroup 型の型引数を持つインターフェースを実装する org.springframework.integration.aggregator のクラス型 MessageGroup の引数を持つ型を返す org.springframework.integration.aggregator のメソッド修飾子と型メソッド説明protected FunctionSE<MessageGroup, MapSE<StringSE, ObjectSE>> AbstractAggregatingMessageGroupProcessor.getHeadersFunction()型 MessageGroup のパラメーターを持つ org.springframework.integration.aggregator のメソッド修飾子と型メソッド説明protected abstract voidAbstractCorrelatingMessageHandler.afterRelease(MessageGroup group, @Nullable CollectionSE<Message<?>> completedMessages) MessageGroup のリリース後に実行する必要がある追加のロジックを提供できます。protected voidAbstractCorrelatingMessageHandler.afterRelease(MessageGroup group, CollectionSE<Message<?>> completedMessages, boolean timeout) タイムアウトのためにグループが解放または破棄されたために特別なアクションが必要な場合、サブクラスがオーバーライドすることがあります。protected voidAggregatingMessageHandler.afterRelease(MessageGroup messageGroup, @Nullable CollectionSE<Message<?>> completedMessages) グループを完成させ、そのメッセージをすべて削除します。protected voidResequencingMessageHandler.afterRelease(MessageGroup messageGroup, @Nullable CollectionSE<Message<?>> completedMessages) protected voidResequencingMessageHandler.afterRelease(MessageGroup messageGroup, @Nullable CollectionSE<Message<?>> completedMessages, boolean timeout) sizeがsequenceSizeと等しい場合は、グループの削除を実行します。AbstractAggregatingMessageGroupProcessor.aggregateHeaders(MessageGroup group) このデフォルトの実装は、グループ間で競合のないすべてのヘッダーを返すだけです。protected abstract ObjectSEAbstractAggregatingMessageGroupProcessor.aggregatePayloads(MessageGroup group, MapSE<StringSE, ObjectSE> defaultHeaders) protected final ObjectSEDefaultAggregatingMessageGroupProcessor.aggregatePayloads(MessageGroup group, MapSE<StringSE, ObjectSE> headers) protected ObjectSEExpressionEvaluatingMessageGroupProcessor.aggregatePayloads(MessageGroup group, MapSE<StringSE, ObjectSE> headers) グループ内のメッセージ（コレクション）で提供される式を評価し、MessagingTemplateに委譲してダウンストリームに送信します。protected final ObjectSEMethodInvokingMessageGroupProcessor.aggregatePayloads(MessageGroup group, MapSE<StringSE, ObjectSE> headers) DefaultAggregateHeadersFunction.apply(MessageGroup messageGroup) booleanExpressionEvaluatingReleaseStrategy.canRelease(MessageGroup messages) MessageGroupで提供されている式を評価し、結果を返します（ブール値である必要があります）。booleanMessageCountReleaseStrategy.canRelease(MessageGroup group) しきい値を超えるメッセージがあり、以前に解放されていない場合は、グループを解放します。booleanMethodInvokingReleaseStrategy.canRelease(MessageGroup messages) booleanReleaseStrategy.canRelease(MessageGroup group) booleanSequenceSizeReleaseStrategy.canRelease(MessageGroup messageGroup) booleanSimpleSequenceSizeReleaseStrategy.canRelease(MessageGroup group) booleanTimeoutCountSequenceSizeReleaseStrategy.canRelease(MessageGroup messages) protected voidAbstractCorrelatingMessageHandler.completeGroup(ObjectSE correlationKey, MessageGroup group, LockSE lock) protected @Nullable CollectionSE<Message<?>> AbstractCorrelatingMessageHandler.completeGroup(Message<?> message, ObjectSE correlationKey, MessageGroup group, LockSE lock) protected voidAbstractCorrelatingMessageHandler.expireGroup(ObjectSE correlationKey, MessageGroup group, LockSE lock) protected voidAbstractCorrelatingMessageHandler.forceComplete(MessageGroup group) protected @Nullable ObjectSEAbstractCorrelatingMessageHandler.obtainGroupTimeout(MessageGroup group) final ObjectSEAbstractAggregatingMessageGroupProcessor.processMessageGroup(MessageGroup group) DelegatingMessageGroupProcessor.processMessageGroup(MessageGroup group) @Nullable ObjectSEMessageGroupProcessor.processMessageGroup(MessageGroup group) 指定された MessageGroup を処理します。@Nullable ObjectSEResequencingMessageGroupProcessor.processMessageGroup(MessageGroup group) SimpleMessageGroupProcessor.processMessageGroup(MessageGroup group) protected voidAbstractCorrelatingMessageHandler.remove(MessageGroup group) 型 MessageGroup の型引数を持つ org.springframework.integration.aggregator のメソッドパラメーター修飾子と型メソッド説明voidAbstractAggregatingMessageGroupProcessor.setHeadersFunction(FunctionSE<MessageGroup, MapSE<StringSE, ObjectSE>> headersFunction) FunctionSE を指定して、MessageGroupを出力メッセージ用の合成ヘッダーにマップします。型 MessageGroup のパラメーターを持つ org.springframework.integration.aggregator のコンストラクター型の型引数を持つ org.springframework.integration.aggregator のコンストラクターパラメーター MessageGroup修飾子コンストラクター説明DelegatingMessageGroupProcessor(MessageGroupProcessor delegate, FunctionSE<MessageGroup, MapSE<StringSE, ObjectSE>> headersFunction) org.springframework.integration.config 内の MessageGroup 使用
型 MessageGroup の型引数を持つ org.springframework.integration.config のメソッドパラメーター修飾子と型メソッド説明voidAggregatorFactoryBean.setHeadersFunction(FunctionSE<MessageGroup, MapSE<StringSE, ObjectSE>> headersFunction) org.springframework.integration.dsl 内の MessageGroup 使用
型 MessageGroup の型引数を持つ org.springframework.integration.dsl のメソッドパラメーター修飾子と型メソッド説明CorrelationHandlerSpec.groupTimeout(FunctionSE<MessageGroup, ?> groupTimeoutFunction) メッセージグループに基づいて、グループタイムアウトを解決するために呼び出される関数でハンドラーを構成します。AggregatorSpec.headersFunction(FunctionSE<MessageGroup, MapSE<StringSE, ObjectSE>> headersFunction) 完成したMessageGroupに基づいて応答用のヘッダーをマージおよび計算するようにFunctionSE を構成します。org.springframework.integration.file.aggregator 内の MessageGroup 使用
型 MessageGroup のパラメーターを持つ org.springframework.integration.file.aggregator のメソッド修飾子と型メソッド説明protected ObjectSEFileAggregatingMessageGroupProcessor.aggregatePayloads(MessageGroup group, MapSE<StringSE, ObjectSE> defaultHeaders) booleanFileAggregator.canRelease(MessageGroup group) booleanFileMarkerReleaseStrategy.canRelease(MessageGroup group) FileAggregator.processMessageGroup(MessageGroup group) org.springframework.integration.jdbc.store 内の MessageGroup 使用
修飾子と型メソッド説明JdbcChannelMessageStore.addMessageToGroup(ObjectSE groupId, Message<?> message) データベースにメッセージを保存します。JdbcChannelMessageStore.getMessageGroup(ObjectSE groupId) 完全には使用されていません。JdbcMessageStore.getMessageGroup(ObjectSE groupId) 型 MessageGroup の引数を持つ型を返す org.springframework.integration.jdbc.store のメソッドorg.springframework.integration.mongodb.store 内の MessageGroup 使用
修飾子と型メソッド説明ConfigurableMongoDbMessageStore.addMessageToGroup(ObjectSE groupId, Message<?> message) MongoDbChannelMessageStore.addMessageToGroup(ObjectSE groupId, Message<?> message) ConfigurableMongoDbMessageStore.getMessageGroup(ObjectSE groupId) MongoDbChannelMessageStore.getMessageGroup(ObjectSE groupId) 完全には使用されていません。MongoDbMessageStore.getMessageGroup(ObjectSE groupId) 型 MessageGroup の引数を持つ型を返す org.springframework.integration.mongodb.store のメソッドorg.springframework.integration.redis.store 内の MessageGroup 使用
修飾子と型メソッド説明RedisChannelMessageStore.addMessageToGroup(ObjectSE groupId, Message<?> message) RedisChannelPriorityMessageStore.addMessageToGroup(ObjectSE groupId, Message<?> message) RedisChannelMessageStore.getMessageGroup(ObjectSE groupId) RedisChannelPriorityMessageStore.getMessageGroup(ObjectSE groupId) org.springframework.integration.store 内の MessageGroup 使用
MessageGroup を実装している org.springframework.integration.store のクラスMessageGroup 型の型引数を持つインターフェースを実装する org.springframework.integration.store のクラス修飾子と型メソッド説明AbstractMessageGroupStore.addMessageToGroup(ObjectSE groupId, Message<?> message) BasicMessageGroupStore.addMessageToGroup(ObjectSE groupId, Message<?> message) グループ ID に関連付けてメッセージを保存します。protected MessageGroupAbstractMessageGroupStore.copy(MessageGroup group) expireMessageGroups で使用されます。protected MessageGroupSimpleMessageStore.copy(MessageGroup group) 提供されたgroupIdに基づいてMessageGroupインスタンスを作成します。MessageGroupFactory.create(CollectionSE<? extends Message<?>> messages, ObjectSE groupId) MessageGroupFactory.create(CollectionSE<? extends Message<?>> messages, ObjectSE groupId, long timestamp, boolean complete) MessageGroupFactory.create(MessageGroupStore messageGroupStore, ObjectSE groupId) 提供されたgroupIdに基づいてMessageGroupインスタンスを作成します。MessageGroupFactory.create(MessageGroupStore messageGroupStore, ObjectSE groupId, long timestamp, boolean complete) 提供されたgroupIdに基づいてMessageGroupインスタンスを作成します。SimpleMessageGroupFactory.create(CollectionSE<? extends Message<?>> messages, ObjectSE groupId) SimpleMessageGroupFactory.create(CollectionSE<? extends Message<?>> messages, ObjectSE groupId, long timestamp, boolean complete) SimpleMessageGroupFactory.create(MessageGroupStore messageGroupStore, ObjectSE groupId) SimpleMessageGroupFactory.create(MessageGroupStore messageGroupStore, ObjectSE groupId, long timestamp, boolean complete) AbstractKeyValueMessageStore.getMessageGroup(ObjectSE groupId) 必要に応じて、SimpleMessageGroup の新しいインスタンスを作成します。BasicMessageGroupStore.getMessageGroup(ObjectSE groupId) このグループ ID でBasicMessageGroupStore.addMessageToGroup(Object, Message)を使用して保存された、現在 MessageStore にあるすべてのメッセージを返します。SimpleMessageStore.getMessageGroup(ObjectSE groupId) 型 MessageGroup の引数を持つ型を返す org.springframework.integration.store のメソッド修飾子と型メソッド説明AbstractKeyValueMessageStore.iterator()MessageGroupStore.iterator()SimpleMessageStore.iterator()型 MessageGroup のパラメーターを持つ org.springframework.integration.store のメソッド修飾子と型メソッド説明protected MessageGroupAbstractMessageGroupStore.copy(MessageGroup group) expireMessageGroups で使用されます。protected MessageGroupSimpleMessageStore.copy(MessageGroup group) voidMessageGroupStore.MessageGroupCallback.execute(MessageGroupStore messageGroupStore, MessageGroup group) 型 MessageGroup のパラメーターを持つ org.springframework.integration.store のコンストラクター修飾子コンストラクター説明MessageGroupMetadata(MessageGroup messageGroup) SimpleMessageGroup(MessageGroup messageGroup)