インターフェース MessageGroup

メソッドの詳細

• canAdd

  boolean canAdd(Message<?> message)

  メッセージを追加できるかどうかを照会します。

  パラメーター:

  message - メッセージ。

  戻り値:

  メッセージを追加できる場合は true。

• add

  void add(Message<?> messageToAdd)

  このグループにメッセージを追加します。

  パラメーター:

  messageToAdd - 追加するメッセージ。

  導入:

  4.3

• remove

  boolean remove(Message<?> messageToRemove)

  このグループからメッセージを削除します。

  パラメーター:

  messageToRemove - 削除するメッセージ。

  戻り値:

  メッセージが削除された場合は true。

  導入:

  4.3

• getMessages

  CollectionSE<Message<?>> getMessages()

  呼び出し時にグループから使用可能なすべてのメッセージを返します。

  戻り値:

  メッセージ。

• streamMessages

  default StreamSE<Message<?>> streamMessages()

  このグループに保存されているメッセージのストリームを返します。

  戻り値:

  このグループのメッセージの StreamSE。

  導入:

  5.5

• getGroupId

  ObjectSE getGroupId()

  戻り値:

  これらのメッセージをリンクするキー

• getLastReleasedMessageSequenceNumber

  int getLastReleasedMessageSequenceNumber()

  戻り値:

  最後にリリースされたメッセージの sequenceNumber。Resequencer の使用例でのみ使用されます

• setLastReleasedMessageSequenceNumber

  void setLastReleasedMessageSequenceNumber(int sequenceNumber)

• isComplete

  boolean isComplete()

  戻り値:

  グループが完了している場合は true (つまり、これ以上メッセージが追加されることはありません)

• complete

  void complete()

  グループを完了します。

• getSequenceSize

  int getSequenceSize()

  戻り値:

  不明な場合、シーケンスのサイズは 0 と予想されます

• size

  int size()

  戻り値:

  このグループのメッセージの総数

• getOne

  @Nullable Message<?> getOne()

  戻り値:

  グループからの単一のメッセージ

• getTimestamp

  long getTimestamp()

  戻り値:

  このグループの作成に関連付けられたタイムスタンプ（エポックからのミリ秒）

• getLastModified

  long getLastModified()

  戻り値:

  このグループが最後に更新された時刻に関連付けられたタイムスタンプ（エポックからのミリ秒）

• setLastModified

  void setLastModified(long lastModified)

• setCondition

  void setCondition(@Nullable StringSE condition)

  このグループに条件ステートメントを追加します。これは後で参照できます。リリース戦略から。

  パラメーター:

  condition - 後で参照できるステートメント。例: リリース戦略から。

  導入:

  5.5

• getCondition

  @Nullable StringSE getCondition()

  このグループが相談する条件を返します。例: リリース戦略から。

  戻り値:

  このグループが相談する条件、たとえばリリース戦略から。

  導入:

  5.5

• clear

  void clear()