org.hornetq.core.paging.cursor.impl

Class PageCursorProviderImpl

java.lang.Object

org.hornetq.core.paging.cursor.impl.PageCursorProviderImpl

All Implemented Interfaces:

PageCursorProvider

public class PageCursorProviderImpl
extends Object
implements PageCursorProvider

A PageProviderIMpl TODO: this may be moved entirely into PagingStore as there's an one-to-one relationship here However I want to keep this isolated as much as possible during development

Author:

Clebert Suconic

Constructor Summary

Constructors

Constructor and Description
PageCursorProviderImpl(PagingStore pagingStore, StorageManager storageManager, Executor executor, int maxCacheSize)

Method Summary

Methods

Modifier and Type	Method and Description
void	addPageCache(PageCache cache)
void	cleanup()
void	close(PageSubscription cursor)
protected PageCacheImpl	createPageCache(long pageId)
PageSubscription	createSubscription(long cursorID, Filter filter, boolean persistent)
void	flushExecutors()
PagingStore	getAssociatedStore()
int	getCacheMaxSize()
int	getCacheSize()
PagedMessage	getMessage(PagePosition pos)
PageCache	getPageCache(long pageId)
PageCache	getPageCache(PagePosition pos) No need to synchronize this method since the private getPageCache will have a synchronized call
PageSubscription	getSubscription(long cursorID)
PagedReference	newReference(PagePosition pos, PagedMessage msg, PageSubscription subscription)
void	printDebug()
void	processReload()
void	scheduleCleanup()
void	setCacheMaxSize(int size)
void	stop()
protected void	storePositions(ArrayList<PageSubscription> cursorList, Page currentPage)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PageCursorProviderImpl

public PageCursorProviderImpl(PagingStore pagingStore,
                      StorageManager storageManager,
                      Executor executor,
                      int maxCacheSize)

Method Detail

getAssociatedStore

public PagingStore getAssociatedStore()

Specified by:

getAssociatedStore in interface PageCursorProvider

createSubscription

public PageSubscription createSubscription(long cursorID,
                                  Filter filter,
                                  boolean persistent)

Specified by:

createSubscription in interface PageCursorProvider

getSubscription

public PageSubscription getSubscription(long cursorID)

Specified by:

getSubscription in interface PageCursorProvider

Parameters:

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

Returns:

getMessage

public PagedMessage getMessage(PagePosition pos)
                        throws Exception

Specified by:

getMessage in interface PageCursorProvider

Throws:

Exception

newReference

public PagedReference newReference(PagePosition pos,
                          PagedMessage msg,
                          PageSubscription subscription)

Specified by:

newReference in interface PageCursorProvider

getPageCache

public PageCache getPageCache(PagePosition pos)

No need to synchronize this method since the private getPageCache will have a synchronized call

Specified by:

getPageCache in interface PageCursorProvider

getPageCache

public PageCache getPageCache(long pageId)

addPageCache

public void addPageCache(PageCache cache)

Specified by:

addPageCache in interface PageCursorProvider

getCacheMaxSize

public int getCacheMaxSize()

Specified by:

getCacheMaxSize in interface PageCursorProvider

setCacheMaxSize

public void setCacheMaxSize(int size)

Specified by:

setCacheMaxSize in interface PageCursorProvider

getCacheSize

public int getCacheSize()

Specified by:

getCacheSize in interface PageCursorProvider

processReload

public void processReload()
                   throws Exception

Specified by:

processReload in interface PageCursorProvider

Throws:

Exception

stop

public void stop()

Specified by:

stop in interface PageCursorProvider

flushExecutors

public void flushExecutors()

Specified by:

flushExecutors in interface PageCursorProvider

close

public void close(PageSubscription cursor)

Specified by:

close in interface PageCursorProvider

scheduleCleanup

public void scheduleCleanup()

Specified by:

scheduleCleanup in interface PageCursorProvider

cleanup

public void cleanup()

Specified by:

cleanup in interface PageCursorProvider

storePositions

protected void storePositions(ArrayList<PageSubscription> cursorList,
                  Page currentPage)
                       throws Exception

Parameters:

cursorList -

currentPage -

Throws:

Exception

printDebug

public void printDebug()

Specified by:

printDebug in interface PageCursorProvider

createPageCache

protected PageCacheImpl createPageCache(long pageId)
                                 throws Exception

Throws:

Exception