protected static class RingBookmarkStore.Subscription extends java.lang.Object implements Subscription
Constructor and Description |
---|
Subscription() |
Modifier and Type | Method and Description |
---|---|
void |
discard(long bookmark) |
Field |
getMostRecent() |
Field |
getMostRecentList(boolean useList) |
long |
getOldestBookmarkSeq() |
BookmarkRangeField |
getRange() |
void |
init(java.nio.ByteBuffer buffer,
int offset) |
boolean |
isDiscarded(BookmarkField bookmark) |
long |
log(BookmarkField bookmark) |
void |
setLastPersisted(BookmarkField bookmark) |
void |
setLastPersisted(long bookmark)
Deprecated.
|
void |
setResizeHandler(BookmarkStoreResizeHandler handler,
BookmarkStore store) |
public void init(java.nio.ByteBuffer buffer, int offset) throws AMPSException
AMPSException
public long log(BookmarkField bookmark) throws CommandException
log
in interface Subscription
CommandException
public boolean isDiscarded(BookmarkField bookmark)
isDiscarded
in interface Subscription
public void discard(long bookmark)
discard
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)
setLastPersisted
in interface Subscription
public void setLastPersisted(BookmarkField bookmark)
setLastPersisted
in interface Subscription
public long getOldestBookmarkSeq()
getOldestBookmarkSeq
in interface Subscription
public void setResizeHandler(BookmarkStoreResizeHandler handler, BookmarkStore store)
setResizeHandler
in interface Subscription