クラス SimpleMessageStore

java.lang.ObjectSE
org.springframework.integration.store.AbstractBatchingMessageGroupStore
org.springframework.integration.store.AbstractMessageGroupStore
org.springframework.integration.store.SimpleMessageStore
実装済みのインターフェース一覧:
IterableSE<MessageGroup>, IntegrationPattern, BasicMessageGroupStore, ChannelMessageStore, MessageGroupStore, MessageStore
public class SimpleMessageStore extends AbstractMessageGroupStore implements MessageStore, ChannelMessageStore
MessageStore および MessageGroupStore のマップベースのメモリ内実装。ストアの最大容量を強制します。
導入:
2.0
作成者:
Iwein Fuld, Mark Fisher, Dave Syer, Oleg Zhurakousky, Gary Russell, Ryan Barker, Artem Bilan, Youbin Wu

  • コンストラクターの詳細

    • SimpleMessageStore

      public SimpleMessageStore(int individualCapacity, int groupCapacity)
      最大サイズが指定された容量によって制限されるか、指定された容量が 1 未満の場合は無制限のサイズで SimpleMessageStore を作成します。容量は、addMessage(Message) を介して保存されたメッセージと AbstractMessageGroupStore.addMessageToGroup(Object, Message) を介して保存されたメッセージに個別に適用されます。どちらの場合も、容量は保存できるメッセージの数に適用され、その制限に達すると、別のメッセージを保存しようとすると例外が発生します。
      パラメーター:
      individualCapacity - メッセージ容量。
      groupCapacity - 各グループの容量。

    • SimpleMessageStore

      public SimpleMessageStore(int individualCapacity, int groupCapacity, long upperBoundTimeout)
      最大サイズが指定された容量とミリ秒単位のタイムアウトによって制限された SimpleMessageStore を作成して、ストアの空のスロットを待機します。
      パラメーター:
      individualCapacity - メッセージ容量。
      groupCapacity - 各グループの容量。
      upperBoundTimeout - ストアが最大容量に達した場合に待機する時間。
      導入:
      4.3
      関連事項:

    • SimpleMessageStore

      public SimpleMessageStore(int individualCapacity, int groupCapacity, LockRegistry<?> lockRegistry)
      指定された容量によって制限される最大サイズの SimpleMessageStore と、メッセージグループ操作の同時実行性のための LockRegistry を作成します。
      パラメーター:
      individualCapacity - メッセージ容量。
      groupCapacity - 各グループの容量。
      lockRegistry - ロックレジストリ。
      関連事項:

    • SimpleMessageStore

      public SimpleMessageStore(int individualCapacity, int groupCapacity, long upperBoundTimeout, LockRegistry<?> lockRegistry)
      指定された容量によって制限される最大サイズ、ストア内の空のスロットを待機するためのミリ秒単位のタイムアウト、メッセージグループ操作の同時実行のための LockRegistry を使用して SimpleMessageStore を作成します。
      パラメーター:
      individualCapacity - メッセージ容量。
      groupCapacity - 各グループの容量。
      upperBoundTimeout - ストアが最大容量にある場合に待機する時間
      lockRegistry - ロックレジストリ。
      導入:
      4.3

    • SimpleMessageStore

      public SimpleMessageStore(int capacity)
      個別のメッセージとグループ化されたメッセージに対して同じ容量の SimpleMessageStore を作成します。
      パラメーター:
      capacity - 容量。

    • SimpleMessageStore

      public SimpleMessageStore()
      容量無制限の SimpleMessageStore を作成します。

  • 方法の詳細

    • setCopyOnGet

      public void setCopyOnGet(boolean copyOnGet)
      false に設定すると、getMessageGroup(Object) でのグループのコピーが無効になります。4.1 以降、これはデフォルトで false です。
      パラメーター:
      copyOnGet - コピーする場合は true、コピーしない場合は false。
      導入:
      4.0.1

    • setLazyLoadMessageGroups

      public void setLazyLoadMessageGroups(boolean lazyLoadMessageGroups)
      クラスからコピーされた説明: AbstractMessageGroupStore
      BasicMessageGroupStore.getMessageGroup(Object) の結果を PersistentMessageGroup にラップするかどうかを指定します。グループのメッセージの遅延ロードプロキシデフォルトは true です。

      ターゲットロジックは SimpleMessageGroupFactory.GroupType.PERSISTENT に基づいています。

      オーバーライド:
      クラス AbstractMessageGroupStore の setLazyLoadMessageGroups 
      パラメーター:
      lazyLoadMessageGroups - 使用する boolean フラグ。

    • getMessageCount

      @ManagedAttribute public long getMessageCount()
      インターフェースからコピーされた説明: MessageStore
      ストア内のメッセージ数を示すオプションの属性。実装は例外をスローすることで応答を拒否する場合があります。
      次で指定:
      インターフェース MessageStore 内の getMessageCount 
      戻り値:
      メッセージの数。

    • addMessage

      public <T> Message<T> addMessage(Message<T> message)
      インターフェースからコピーされた説明: MessageStore
      提供されたメッセージを MessageStore に格納します。ストアは内部的にメッセージを変更する必要がある可能性があり、その場合、戻り値は入力値と異なる場合があります。戻り値の ID は、MessageStore.getMessage(UUID) と MessageStore.removeMessage(UUID) が正しく動作するためのインデックスとして使用されます。メッセージは不変であるため、同じメッセージを複数回格納しても何も起こりません。
      次で指定:
      インターフェース MessageStore 内の addMessage 
      型パラメーター:
      T - ペイロード型。
      パラメーター:
      message - メッセージ。
      戻り値:
      保存されたメッセージ。

    • getMessage

      public @Nullable Message<?> getMessage(UUIDSE key)
      次で指定:
      インターフェース MessageStore 内の getMessage 
      パラメーター:
      key - メッセージ識別子。
      戻り値:
      指定された ID のメッセージ。MessageStore にその ID のメッセージが存在しない場合は null。

    • getMessageMetadata

      public @Nullable MessageMetadata getMessageMetadata(UUIDSE id)
      インターフェースからコピーされた説明: MessageStore
      提供された id によって Message の MessageMetadata を返します。
      次で指定:
      インターフェース MessageStore 内の getMessageMetadata 
      パラメーター:
      id - メッセージ識別子。
      戻り値:
      指定された ID の MessageMetadata、またはその ID のメッセージが MessageStore に存在しないか、メッセージにメタデータがない場合（以前のバージョンのレガシーメッセージ）は null。

    • removeMessage

      public @Nullable Message<?> removeMessage(UUIDSE key)
      インターフェースからコピーされた説明: MessageStore
      指定された ID を持つメッセージが MessageStore から削除されます (存在する場合)。その ID を持つメッセージがストアに存在しない場合は、null が返されます。このメソッドが MessageGroupStore に実装されている場合、このメッセージを保持するグループがない場合にのみ、メッセージはストアから削除されます。
      次で指定:
      インターフェース MessageStore 内の removeMessage 
      パラメーター:
      key - メッセージ識別子。
      戻り値:
      メッセージ (ある場合)。

    • getMessageGroup

      public MessageGroup getMessageGroup(ObjectSE groupId)
      インターフェースからコピーされた説明: BasicMessageGroupStore
      このグループ ID で BasicMessageGroupStore.addMessageToGroup(Object, Message) を使用して保存された、現在 MessageStore にあるすべてのメッセージを返します。
      次で指定:
      インターフェース BasicMessageGroupStore 内の getMessageGroup 
      パラメーター:
      groupId - グループ識別子。
      戻り値:
      メッセージのグループ。このキーにメッセージが存在しない場合は空です。

    • copy

      protected MessageGroup copy(MessageGroup group)
      クラスからコピーされた説明: AbstractMessageGroupStore
      expireMessageGroups によって使用されます。グループが現在から期限切れになるまでの間に変更されたかどうかを適切に検出できるように、リーパーの実行時にグループのスナップショットを返す必要があります。永続ストアには必要ないため、デフォルトの動作ではグループのみを返します。
      オーバーライド:
      クラス AbstractMessageGroupStore の copy 
      パラメーター:
      group - グループ。
      戻り値:
      グループ、またはコピー。

    • addMessagesToGroup

      public void addMessagesToGroup(ObjectSE groupId, Message<?>... messages)
      インターフェースからコピーされた説明: MessageGroupStore
      グループ ID に関連付けてメッセージを保存します。これは、メッセージをグループ化するために使用できます。
      次で指定:
      インターフェース MessageGroupStore 内の addMessagesToGroup 
      オーバーライド:
      クラス AbstractMessageGroupStore の addMessagesToGroup 
      パラメーター:
      groupId - メッセージを保存するグループ ID。
      messages - 追加するメッセージ。

    • doAddMessagesToGroup

      protected void doAddMessagesToGroup(ObjectSE groupId, Message<?>... messages)
      次で指定:
      クラス AbstractMessageGroupStore の doAddMessagesToGroup 

    • doRemoveMessageGroup

      protected void doRemoveMessageGroup(ObjectSE groupId)
      次で指定:
      クラス AbstractMessageGroupStore の doRemoveMessageGroup 

    • doRemoveMessagesFromGroup

      protected void doRemoveMessagesFromGroup(ObjectSE groupId, CollectionSE<Message<?>> messages)
      次で指定:
      クラス AbstractMessageGroupStore の doRemoveMessagesFromGroup 

    • getMessageFromGroup

      public @Nullable Message<?> getMessageFromGroup(ObjectSE groupId, UUIDSE messageId)
      インターフェースからコピーされた説明: MessageGroupStore
      ID を使用してグループから Message を取得します。メッセージがリクエストされたグループに属していない場合は、null を返します。
      次で指定:
      インターフェース MessageGroupStore 内の getMessageFromGroup 
      パラメーター:
      groupId - メッセージを含むグループの groupId。
      messageId - メッセージ ID。
      戻り値:
      リクエストされたグループに属している場合は、ID によるメッセージ。

    • doRemoveMessageFromGroupById

      protected boolean doRemoveMessageFromGroupById(ObjectSE groupId, UUIDSE messageId)
      オーバーライド:
      クラス AbstractMessageGroupStore の doRemoveMessageFromGroupById 

    • iterator

      public IteratorSE<MessageGroup> iterator()
      次で指定:
      インターフェース IterableSE<MessageGroup> 内の iterator 
      次で指定:
      インターフェース MessageGroupStore 内の iterator 
      戻り値:
      現在累積されている MessageGroup の反復子。

    • doSetGroupCondition

      protected void doSetGroupCondition(ObjectSE groupId, StringSE condition)
      次で指定:
      クラス AbstractMessageGroupStore の doSetGroupCondition 

    • doSetLastReleasedSequenceNumberForGroup

      protected void doSetLastReleasedSequenceNumberForGroup(ObjectSE groupId, int sequenceNumber)
      次で指定:
      クラス AbstractMessageGroupStore の doSetLastReleasedSequenceNumberForGroup 

    • doCompleteGroup

      protected void doCompleteGroup(ObjectSE groupId)
      次で指定:
      クラス AbstractMessageGroupStore の doCompleteGroup 

    • doPollMessageFromGroup

      protected @Nullable Message<?> doPollMessageFromGroup(ObjectSE groupId)
      次で指定:
      クラス AbstractMessageGroupStore の doPollMessageFromGroup 

    • messageGroupSize

      public int messageGroupSize(ObjectSE groupId)
      インターフェースからコピーされた説明: BasicMessageGroupStore
      この MessageGroup のサイズを返します。
      次で指定:
      インターフェース BasicMessageGroupStore 内の messageGroupSize 
      パラメーター:
      groupId - グループ識別子。
      戻り値:
      サイズ。

    • getGroupMetadata

      public MessageGroupMetadata getGroupMetadata(ObjectSE groupId)
      インターフェースからコピーされた説明: MessageGroupStore
      メッセージをフェッチせずにグループメタデータを取得します。他のすべてのグループプロパティを提供する必要があります。最初のメッセージの ID を含めることができます。
      次で指定:
      インターフェース MessageGroupStore 内の getGroupMetadata 
      パラメーター:
      groupId - グループ ID。
      戻り値:
      メタデータ。

    • getOneMessageFromGroup

      public @Nullable Message<?> getOneMessageFromGroup(ObjectSE groupId)
      インターフェースからコピーされた説明: MessageGroupStore
      MessageGroup から 1 つの Message を返します。
      次で指定:
      インターフェース MessageGroupStore 内の getOneMessageFromGroup 
      パラメーター:
      groupId - グループ識別子。
      戻り値:
      Message

    • getMessagesForGroup

      public CollectionSE<Message<?>> getMessagesForGroup(ObjectSE groupId)
      インターフェースからコピーされた説明: MessageGroupStore
      指定されたグループ ID のメッセージを取得します。
      次で指定:
      インターフェース MessageGroupStore 内の getMessagesForGroup 
      パラメーター:
      groupId - メッセージを取得するグループ ID。
      戻り値:
      グループのメッセージ。

    • clearMessageGroup

      public void clearMessageGroup(ObjectSE groupId)