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
AMPSExceptionpublic long log(BookmarkField bookmark) throws CommandException
log in interface SubscriptionCommandExceptionpublic boolean isDiscarded(BookmarkField bookmark)
isDiscarded in interface Subscriptionpublic void discard(long bookmark)
discard in interface Subscriptionpublic BookmarkRangeField getRange()
getRange in interface Subscriptionpublic Field getMostRecent()
getMostRecent in interface Subscriptionpublic Field getMostRecentList(boolean useList)
getMostRecentList in interface Subscription@Deprecated public void setLastPersisted(long bookmark)
setLastPersisted in interface Subscriptionpublic void setLastPersisted(BookmarkField bookmark)
setLastPersisted in interface Subscriptionpublic long getOldestBookmarkSeq()
getOldestBookmarkSeq in interface Subscriptionpublic void setResizeHandler(BookmarkStoreResizeHandler handler, BookmarkStore store)
setResizeHandler in interface Subscription