クラス SimpleMessageGroup

java.lang.ObjectSE
org.springframework.integration.store.SimpleMessageGroup
実装されているすべてのインターフェース:
MessageGroup
既知の直属サブクラス
AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup
public class SimpleMessageGroup extends ObjectSE implements MessageGroup
特定の MessageStore およびグループ ID にバインドされている相関メッセージの可変グループを表します。グループは、メッセージが add(org.springframework.messaging.Message<?>) されたときに、その存続期間中に成長します。この MessageGroup はスレッドセーフです。
導入:
2.0
作成者:
Iwein Fuld, Oleg Zhurakousky, Dave Syer, Gary Russell, Artem Bilan, Christian Tzolov

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

    • SimpleMessageGroup

      public SimpleMessageGroup(ObjectSE groupId)

    • SimpleMessageGroup

      public SimpleMessageGroup(CollectionSE<? extends Message<?>> messages, ObjectSE groupId)

    • SimpleMessageGroup

      public SimpleMessageGroup(MessageGroup messageGroup)

    • SimpleMessageGroup

      public SimpleMessageGroup(CollectionSE<? extends Message<?>> messages, ObjectSE groupId, long timestamp, boolean complete)

    • SimpleMessageGroup

      public SimpleMessageGroup(CollectionSE<Message<?>> internalStore, CollectionSE<? extends Message<?>> messages, ObjectSE groupId, long timestamp, boolean complete, boolean storePreLoaded)

  • メソッドの詳細

    • getTimestamp

      public long getTimestamp()
      次で指定:
      インターフェース MessageGroup の getTimestamp 
      戻り値:
      このグループの作成に関連付けられたタイムスタンプ（エポックからのミリ秒）

    • setLastModified

      public void setLastModified(long lastModified)
      次で指定:
      インターフェース MessageGroup の setLastModified 

    • getLastModified

      public long getLastModified()
      次で指定:
      インターフェース MessageGroup の getLastModified 
      戻り値:
      このグループが最後に更新された時刻に関連付けられたタイムスタンプ（エポックからのミリ秒）

    • canAdd

      public boolean canAdd(Message<?> message)
      インターフェースからコピーされた説明: MessageGroup
      メッセージを追加できるかどうかを照会します。
      次で指定:
      インターフェース MessageGroup の canAdd 
      パラメーター:
      message - メッセージ。
      戻り値:
      メッセージを追加できる場合は true。

    • add

      public void add(Message<?> messageToAdd)
      インターフェースからコピーされた説明: MessageGroup
      このグループにメッセージを追加します。
      次で指定:
      インターフェース MessageGroup の add 
      パラメーター:
      messageToAdd - 追加するメッセージ。

    • remove

      public boolean remove(Message<?> message)
      インターフェースからコピーされた説明: MessageGroup
      このグループからメッセージを削除します。
      次で指定:
      インターフェース MessageGroup の remove 
      パラメーター:
      message - 削除するメッセージ。
      戻り値:
      メッセージが削除された場合は true。

    • getLastReleasedMessageSequenceNumber

      public int getLastReleasedMessageSequenceNumber()
      次で指定:
      インターフェース MessageGroup の getLastReleasedMessageSequenceNumber 
      戻り値:
      最後にリリースされたメッセージの sequenceNumber。Resequencer の使用例でのみ使用されます

    • getMessages

      public CollectionSE<Message<?>> getMessages()
      インターフェースからコピーされた説明: MessageGroup
      呼び出し時にグループから使用可能なすべてのメッセージを返します。
      次で指定:
      インターフェース MessageGroup の getMessages 
      戻り値:
      メッセージ。

    • setLastReleasedMessageSequenceNumber

      public void setLastReleasedMessageSequenceNumber(int sequenceNumber)
      次で指定:
      インターフェース MessageGroup の setLastReleasedMessageSequenceNumber 

    • getGroupId

      public ObjectSE getGroupId()
      次で指定:
      インターフェース MessageGroup の getGroupId 
      戻り値:
      これらのメッセージをリンクするキー

    • isComplete

      public boolean isComplete()
      次で指定:
      インターフェース MessageGroup の isComplete 
      戻り値:
      グループが完了している場合は true (つまり、これ以上メッセージが追加されることはありません)

    • complete

      public void complete()
      インターフェースからコピーされた説明: MessageGroup
      グループを完了します。
      次で指定:
      インターフェース MessageGroup の complete 

    • getSequenceSize

      public int getSequenceSize()
      次で指定:
      インターフェース MessageGroup の getSequenceSize 
      戻り値:
      不明な場合、シーケンスのサイズは 0 と予想されます

    • size

      public int size()
      次で指定:
      インターフェース MessageGroup の size 
      戻り値:
      このグループのメッセージの総数

    • setCondition

      public void setCondition(StringSE condition)
      インターフェースからコピーされた説明: MessageGroup
      このグループに条件ステートメントを追加します。これは後で参照できます。リリース戦略から。
      次で指定:
      インターフェース MessageGroup の setCondition 
      パラメーター:
      condition - 後で参照できるステートメント。例: リリース戦略から。

    • getCondition

      @Nullable public StringSE getCondition()
      インターフェースからコピーされた説明: MessageGroup
      このグループが相談する条件を返します。例: リリース戦略から。
      次で指定:
      インターフェース MessageGroup の getCondition 
      戻り値:
      このグループが相談する条件、たとえばリリース戦略から。

    • getOne

      public Message<?> getOne()
      次で指定:
      インターフェース MessageGroup の getOne 
      戻り値:
      グループからの単一のメッセージ

    • clear

      public void clear()
      次で指定:
      インターフェース MessageGroup の clear 

    • containsSequence

      public boolean containsSequence(IntegerSE sequence)
      このシーケンス番号ヘッダーを持つメッセージがグループに存在する場合は true を返します。
      パラメーター:
      sequence - シーケンス番号。
      戻り値:
      存在する場合は true。
      導入:
      4.3.7

    • toString

      public StringSE toString()
      オーバーライド:
      クラス ObjectSE の toString