@ManagedResource public abstract class AbstractMessageGroupStore extends AbstractBatchingMessageGroupStore implements MessageGroupStore, IterableSE<MessageGroup>
MessageGroupStore.MessageGroupCallback| 修飾子 | コンストラクターと説明 |
|---|---|
protected | AbstractMessageGroupStore() |
protected | AbstractMessageGroupStore(boolean lazyLoadMessageGroups) |
| 修飾子と型 | メソッドと説明 |
|---|---|
MessageGroup | addMessageToGroup(ObjectSE groupId, Message<?> message) グループ ID に関連付けてメッセージを保存します。 |
protected MessageGroup | copy(MessageGroup group)expireMessageGroups で使用されます。 |
int | expireMessageGroups(long timeout) 期限切れのグループ(タイムスタンプが現在の時刻から指定されたしきい値を差し引いたものより古い)をすべて抽出し、登録されている各コールバックを順番に呼び出します。 |
MessageGroupMetadata | getGroupMetadata(ObjectSE groupId) メッセージをフェッチせずにグループメタデータを取得します。他のすべてのグループプロパティを提供する必要があります。最初のメッセージの ID を含めることができます。 |
int | getMessageCountForAllMessageGroups() すべてのグループにわたるストア内のメッセージの数を示すオプションの属性。 |
int | getMessageGroupCount() メッセージグループの数を示すオプションの属性。 |
protected MessageGroupFactory | getMessageGroupFactory() |
boolean | isTimeoutOnIdle() |
void | registerMessageGroupExpiryCallback(MessageGroupStore.MessageGroupCallback callback) メッセージグループが MessageGroupStore.expireMessageGroups(long) を介して期限切れになったときのコールバックを登録します。 |
void | removeMessagesFromGroup(ObjectSE key, Message<?>... messages) グループからのメッセージの削除を永続化します。 |
void | setExpiryCallbacks(CollectionSE<MessageGroupStore.MessageGroupCallback> expiryCallbacks) メッセージストアでの有効期限コールバックの便利なインジェクションポイント。 |
void | setLazyLoadMessageGroups(boolean lazyLoadMessageGroups)BasicMessageGroupStore.getMessageGroup(Object) の結果を PersistentMessageGroup にラップするかどうかを指定します。グループのメッセージの遅延ロードプロキシデフォルトは true です。 |
void | setTimeoutOnIdle(boolean timeoutOnIdle) タイムアウト計算のルールを上書きできます。 |
getRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSizecloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEaddMessagesToGroup, completeGroup, getMessagesForGroup, getOneMessageFromGroup, iterator, removeMessagesFromGroup, setLastReleasedSequenceNumberForGroupgetMessageGroup, messageGroupSize, pollMessageFromGroup, removeMessageGroupforEachSE, iteratorSE, spliteratorSEprotected final Log logger
protected AbstractMessageGroupStore()
protected AbstractMessageGroupStore(boolean lazyLoadMessageGroups)
protected MessageGroupFactory getMessageGroupFactory()
AbstractBatchingMessageGroupStore の getMessageGroupFactory public void setExpiryCallbacks(CollectionSE<MessageGroupStore.MessageGroupCallback> expiryCallbacks)
MessageGroupStore.registerMessageGroupExpiryCallback(MessageGroupCallback) を使用してストアに登録されるだけです。expiryCallbacks - 追加する有効期限コールバック public boolean isTimeoutOnIdle()
public void setTimeoutOnIdle(boolean timeoutOnIdle)
MessageGroup が作成された時間に基づいています。MessageGroup がアイドリングしていた時間に基づいてタイムアウトを設定する場合(たとえば、最後の更新から非アクティブ)、"true" を指定してこのメソッドを呼び出します。デフォルトは "false" です。timeoutOnIdle - ブール値。public void setLazyLoadMessageGroups(boolean lazyLoadMessageGroups)
BasicMessageGroupStore.getMessageGroup(Object) の結果を PersistentMessageGroup にラップするかどうかを指定します。グループのメッセージの遅延ロードプロキシデフォルトは true です。 ターゲットロジックは SimpleMessageGroupFactory.GroupType.PERSISTENT に基づいています。
lazyLoadMessageGroups - 使用する boolean フラグ。public void registerMessageGroupExpiryCallback(MessageGroupStore.MessageGroupCallback callback)
MessageGroupStoreMessageGroupStore.expireMessageGroups(long) を介して期限切れになったときのコールバックを登録します。MessageGroupStore の registerMessageGroupExpiryCallback callback - メッセージグループがクリーンアップされたときに実行するコールバック。@ManagedOperation public int expireMessageGroups(long timeout)
MessageGroupStoreMessageGroupStore の expireMessageGroups timeout - 使用するタイムアウトしきい値 MessageGroupStore.registerMessageGroupExpiryCallback(MessageGroupCallback)protected MessageGroup copy(MessageGroup group)
group - グループ。@ManagedAttribute public int getMessageCountForAllMessageGroups()
MessageGroupStoreMessageGroupStore の getMessageCountForAllMessageGroups @ManagedAttribute public int getMessageGroupCount()
MessageGroupStoreMessageGroupStore の getMessageGroupCount public MessageGroupMetadata getGroupMetadata(ObjectSE groupId)
MessageGroupStoreMessageGroupStore の getGroupMetadata groupId - グループ ID。public void removeMessagesFromGroup(ObjectSE key, Message<?>... messages)
MessageGroupStoreMessageGroupStore の removeMessagesFromGroup key - メッセージを含むグループの groupId。messages - 削除するメッセージ。public MessageGroup addMessageToGroup(ObjectSE groupId, Message<?> message)
BasicMessageGroupStoreBasicMessageGroupStore の addMessageToGroup groupId - メッセージを保存するグループ ID。message - メッセージ。