Package org.apache.activemq.artemis.core.paging.cursor

Interface PageCursorProvider

All Known Implementing Classes:

PageCursorProviderImpl

public interface PageCursorProvider

The provider of Cursor for a given Address

Method Summary

Modifier and Type	Method	Description
void	addLivePageCache(LivePageCache cache)
void	cleanup()	Perform the cleanup at the caller's thread (for startup and recovery)
void	clearCache()	Used on tests, to simulate a scenario where the VM cleared space
void	close(PageSubscription pageCursorImpl)
PageSubscription	createSubscription(long queueId, Filter filter, boolean durable)
void	disableCleanup()
void	flushExecutors()
int	getCacheSize()
PagedMessage	getMessage(PagePosition pos)
PageCache	getPageCache(long pageNr)
PageSubscription	getSubscription(long queueId)
PagedReference	newReference(PagePosition pos, PagedMessage msg, PageSubscription sub)
void	onPageModeCleared()	Cleanup stuff as paging mode is being cleared
void	printDebug()
void	processReload()
void	resumeCleanup()
void	scheduleCleanup()
void	setCacheMaxSize(int size)
void	stop()

Method Detail

clearCache

void clearCache()

Used on tests, to simulate a scenario where the VM cleared space

getPageCache

PageCache getPageCache(long pageNr)

newReference

PagedReference newReference(PagePosition pos,
                            PagedMessage msg,
                            PageSubscription sub)

addLivePageCache

void addLivePageCache(LivePageCache cache)

getSubscription

PageSubscription getSubscription(long queueId)

Parameters:

queueId - The cursorID should be the same as the queueId associated for persistence

Returns:

createSubscription

PageSubscription createSubscription(long queueId,
                                    Filter filter,
                                    boolean durable)

getMessage

PagedMessage getMessage(PagePosition pos)

processReload

void processReload()
            throws Exception

Throws:

Exception

stop

void stop()

flushExecutors

void flushExecutors()

scheduleCleanup

void scheduleCleanup()

disableCleanup

void disableCleanup()

resumeCleanup

void resumeCleanup()

onPageModeCleared

void onPageModeCleared()

Cleanup stuff as paging mode is being cleared

cleanup

void cleanup()

Perform the cleanup at the caller's thread (for startup and recovery)

setCacheMaxSize

void setCacheMaxSize(int size)

close

void close(PageSubscription pageCursorImpl)

Parameters:

pageCursorImpl -

getCacheSize

int getCacheSize()

printDebug

void printDebug()