protected static class MemoryBookmarkStore.Subscription extends java.lang.Object implements Subscription
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
_recoveryTimestamp
The last-modified timestamp, if any, from a RecoveryPointAdapter
before recovery is initiated.
|
Constructor and Description |
---|
Subscription() |
Subscription(Field subscriptionId) |
Modifier and Type | Method and Description |
---|---|
void |
discard(long index) |
Field |
getMostRecent() |
Field |
getMostRecentList(boolean useList) |
long |
getOldestBookmarkSeq() |
BookmarkRangeField |
getRange() |
java.lang.String |
getRecoveryTimestamp() |
void |
init(Field subId,
MemoryBookmarkStore parent) |
boolean |
isDiscarded(BookmarkField bookmark)
Check to see if this message is older than the most recent one seen,
and if it is, check if it discarded.
|
long |
log(BookmarkField bookmark) |
void |
reset()
Reset the state of this subscription object such that it can be
returned to the pool for reuse.
|
void |
setLastPersisted(BookmarkField bookmark) |
void |
setLastPersisted(long bookmark)
Deprecated.
use
setLastPersisted(BookmarkField) instead. |
protected void |
setRecoveryTimestamp(java.lang.String rts) |
void |
setResizeHandler(BookmarkStoreResizeHandler handler,
BookmarkStore store) |
protected volatile java.lang.String _recoveryTimestamp
public Subscription(Field subscriptionId)
public Subscription()
public void reset()
public void init(Field subId, MemoryBookmarkStore parent)
public java.lang.String getRecoveryTimestamp()
protected final void setRecoveryTimestamp(java.lang.String rts)
public long log(BookmarkField bookmark) throws java.io.IOException, CommandException
log
in interface Subscription
java.io.IOException
CommandException
public void discard(long index) throws java.io.IOException
discard
in interface Subscription
java.io.IOException
public boolean isDiscarded(BookmarkField bookmark)
isDiscarded
in interface Subscription
public BookmarkRangeField getRange()
getRange
in interface Subscription
public Field getMostRecent()
getMostRecent
in interface Subscription
public Field getMostRecentList(boolean useList)
getMostRecentList
in interface Subscription
@Deprecated public void setLastPersisted(long bookmark) throws java.io.IOException
setLastPersisted(BookmarkField)
instead.setLastPersisted
in interface Subscription
bookmark
- The bookmark to be persisted.java.io.IOException
- if the bookmark was unable to be persisted to the bookmark store.public void setLastPersisted(BookmarkField bookmark) throws java.io.IOException
setLastPersisted
in interface Subscription
java.io.IOException
public long getOldestBookmarkSeq()
getOldestBookmarkSeq
in interface Subscription
public void setResizeHandler(BookmarkStoreResizeHandler handler, BookmarkStore store)
setResizeHandler
in interface Subscription