public interface MessageGroupStore extends BasicMessageGroupStore
| 修飾子と型 | インターフェースと説明 |
|---|---|
static interface | MessageGroupStore.MessageGroupCallbackMessageGroupStore がグループを期限切れにするときに呼び出されます。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | addMessagesToGroup(ObjectSE groupId, Message<?>... messages) グループ ID に関連付けてメッセージを保存します。 |
void | completeGroup(ObjectSE groupId) この MessageGroup を完成させます。 |
int | expireMessageGroups(long timeout) 期限切れのグループ(タイムスタンプが現在の時刻から指定されたしきい値を差し引いたものより古い)をすべて抽出し、登録されている各コールバックを順番に呼び出します。 |
MessageGroupMetadata | getGroupMetadata(ObjectSE groupId) メッセージをフェッチせずにグループメタデータを取得します。他のすべてのグループプロパティを提供する必要があります。最初のメッセージの ID を含めることができます。 |
int | getMessageCountForAllMessageGroups() すべてのグループにわたるストア内のメッセージの数を示すオプションの属性。 |
int | getMessageGroupCount() メッセージグループの数を示すオプションの属性。 |
CollectionSE<Message<?>> | getMessagesForGroup(ObjectSE groupId) 指定されたグループ ID のメッセージを取得します。 |
Message<?> | getOneMessageFromGroup(ObjectSE groupId)MessageGroup から 1 つの Message を返します。 |
IteratorSE<MessageGroup> | iterator() |
void | registerMessageGroupExpiryCallback(MessageGroupStore.MessageGroupCallback callback) メッセージグループが expireMessageGroups(long) を介して期限切れになったときのコールバックを登録します。 |
void | removeMessagesFromGroup(ObjectSE key, CollectionSE<Message<?>> messages) グループからのメッセージの削除を永続化します。 |
void | removeMessagesFromGroup(ObjectSE key, Message<?>... messages) グループからのメッセージの削除を永続化します。 |
void | setLastReleasedSequenceNumberForGroup(ObjectSE groupId, int sequenceNumber) 最後にリリースされたメッセージのシーケンス番号を設定できます。 |
addMessageToGroup, getMessageGroup, messageGroupSize, pollMessageFromGroup, removeMessageGroup@ManagedAttribute int getMessageCountForAllMessageGroups()
UnsupportedOperationExceptionSE - 実装されていない場合 @ManagedAttribute int getMessageGroupCount()
UnsupportedOperationExceptionSE - 実装されていない場合 void removeMessagesFromGroup(ObjectSE key, CollectionSE<Message<?>> messages)
key - メッセージを含むグループの groupId。messages - 削除するメッセージ。void removeMessagesFromGroup(ObjectSE key, Message<?>... messages)
key - メッセージを含むグループの groupId。messages - 削除するメッセージ。void registerMessageGroupExpiryCallback(MessageGroupStore.MessageGroupCallback callback)
expireMessageGroups(long) を介して期限切れになったときのコールバックを登録します。callback - メッセージグループがクリーンアップされたときに実行するコールバック。@ManagedOperation int expireMessageGroups(long timeout)
timeout - 使用するタイムアウトしきい値 registerMessageGroupExpiryCallback(MessageGroupCallback)void setLastReleasedSequenceNumberForGroup(ObjectSE groupId, int sequenceNumber)
groupId - グループ識別子。sequenceNumber - シーケンス番号。IteratorSE<MessageGroup> iterator()
MessageGroup の反復子。void completeGroup(ObjectSE groupId)
groupId - グループ識別子。MessageGroupMetadata getGroupMetadata(ObjectSE groupId)
groupId - グループ ID。Message<?> getOneMessageFromGroup(ObjectSE groupId)
MessageGroup から 1 つの Message を返します。groupId - グループ識別子。Messagevoid addMessagesToGroup(ObjectSE groupId, Message<?>... messages)
groupId - メッセージを保存するグループ ID。messages - 追加するメッセージ。CollectionSE<Message<?>> getMessagesForGroup(ObjectSE groupId)
groupId - メッセージを取得するグループ ID。