public interface PageCursorProvider
Modifier and Type | Method and Description |
---|---|
void |
addPageCache(PageCache cache) |
void |
cleanup() |
void |
close(PageSubscription pageCursorImpl) |
PageSubscription |
createSubscription(long queueId,
Filter filter,
boolean durable) |
void |
flushExecutors() |
PagingStore |
getAssociatedStore() |
int |
getCacheMaxSize() |
int |
getCacheSize() |
PagedMessage |
getMessage(PagePosition pos) |
PageCache |
getPageCache(PagePosition pos) |
PageSubscription |
getSubscription(long queueId) |
PagedReference |
newReference(PagePosition pos,
PagedMessage msg,
PageSubscription sub) |
void |
printDebug() |
void |
processReload() |
void |
scheduleCleanup() |
void |
setCacheMaxSize(int size) |
void |
stop() |
PageCache getPageCache(PagePosition pos)
PagedReference newReference(PagePosition pos, PagedMessage msg, PageSubscription sub)
void addPageCache(PageCache cache)
PagingStore getAssociatedStore()
PageSubscription getSubscription(long queueId)
queueId
- The cursorID should be the same as the queueId associated for persistancePageSubscription createSubscription(long queueId, Filter filter, boolean durable)
PagedMessage getMessage(PagePosition pos) throws Exception
Exception
void stop()
void flushExecutors()
void scheduleCleanup()
void cleanup()
int getCacheMaxSize()
void setCacheMaxSize(int size)
void close(PageSubscription pageCursorImpl)
pageCursorImpl
- int getCacheSize()
void printDebug()
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.