org.hornetq.core.paging.impl

Class PagingStoreImpl

java.lang.Object

org.hornetq.core.paging.impl.PagingStoreImpl

All Implemented Interfaces:

TestSupportPageStore, PagingStore, HornetQComponent

public class PagingStoreImpl
extends Object
implements TestSupportPageStore

Author:

Clebert Suconic, Tim Fox

See Also:

PagingStore

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	syncNonTransactional

Constructor Summary

Constructors

Constructor and Description
PagingStoreImpl(SimpleString address, ScheduledExecutorService scheduledExecutor, long syncTimeout, PagingManager pagingManager, StorageManager storageManager, SequentialFileFactory fileFactory, PagingStoreFactory storeFactory, SimpleString storeName, AddressSettings addressSettings, Executor executor, boolean syncNonTransactional)

Method Summary

Methods

Modifier and Type	Method and Description
void	addSize(int size)
void	applySetting(AddressSettings addressSettings)
boolean	checkPage(int pageNumber)
Page	createPage(int pageNumber)
Page	depage() It returns a Page out of the Page System without reading it.
void	executeRunnableWhenMemoryAvailable(Runnable runnable)
void	flushExecutors() This is used mostly by tests.
void	forceAnotherPage()
SimpleString	getAddress()
AddressFullMessagePolicy	getAddressFullMessagePolicy()
long	getAddressSize()
Page	getCurrentPage()
int	getCurrentWritingPage()
PageCursorProvider	getCursorProvier()
long	getFirstPage()
String	getFolder()
long	getMaxSize()
int	getNumberOfPages()
long	getPageSizeBytes()
PagingManager	getPagingManager()
SimpleString	getStoreName()
long	getTopPage()
void	ioSync()
boolean	isPaging()
boolean	isStarted()
void	lock() This method will hold and producer, but it wait operations to finish before locking (write lock)
boolean	page(ServerMessage message, RoutingContext ctx)
boolean	page(ServerMessage message, RoutingContext ctx, RouteContextList listCtx)
protected boolean	page(ServerMessage message, RoutingContext ctx, RouteContextList listCtx, boolean sync)
void	processReload()
void	start()
boolean	startPaging()
void	stop()
void	stopPaging()
void	sync()
String	toString()
void	unlock() Call this method using the same thread used by the last call of PagingStore.lock()

Methods inherited from class java.lang.Object

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

Field Detail

syncNonTransactional

protected final boolean syncNonTransactional

Constructor Detail

PagingStoreImpl

public PagingStoreImpl(SimpleString address,
               ScheduledExecutorService scheduledExecutor,
               long syncTimeout,
               PagingManager pagingManager,
               StorageManager storageManager,
               SequentialFileFactory fileFactory,
               PagingStoreFactory storeFactory,
               SimpleString storeName,
               AddressSettings addressSettings,
               Executor executor,
               boolean syncNonTransactional)

Method Detail

applySetting

public void applySetting(AddressSettings addressSettings)

Specified by:

applySetting in interface PagingStore

Parameters:

addressSettings -

toString

public String toString()

Overrides:

toString in class Object

lock

public void lock()

Description copied from interface: PagingStore

This method will hold and producer, but it wait operations to finish before locking (write lock)

Specified by:

lock in interface PagingStore

unlock

public void unlock()

Description copied from interface: PagingStore

Call this method using the same thread used by the last call of PagingStore.lock()

Specified by:

unlock in interface PagingStore

getCursorProvier

public PageCursorProvider getCursorProvier()

Specified by:

getCursorProvier in interface PagingStore

getFirstPage

public long getFirstPage()

Specified by:

getFirstPage in interface PagingStore

getTopPage

public long getTopPage()

Specified by:

getTopPage in interface PagingStore

getAddress

public SimpleString getAddress()

Specified by:

getAddress in interface PagingStore

getAddressSize

public long getAddressSize()

Specified by:

getAddressSize in interface PagingStore

getMaxSize

public long getMaxSize()

Specified by:

getMaxSize in interface PagingStore

getAddressFullMessagePolicy

public AddressFullMessagePolicy getAddressFullMessagePolicy()

Specified by:

getAddressFullMessagePolicy in interface PagingStore

getPageSizeBytes

public long getPageSizeBytes()

Specified by:

getPageSizeBytes in interface PagingStore

getFolder

public String getFolder()

Specified by:

getFolder in interface PagingStore

isPaging

public boolean isPaging()

Specified by:

isPaging in interface PagingStore

getNumberOfPages

public int getNumberOfPages()

Specified by:

getNumberOfPages in interface PagingStore

getCurrentWritingPage

public int getCurrentWritingPage()

Specified by:

getCurrentWritingPage in interface PagingStore

getStoreName

public SimpleString getStoreName()

Specified by:

getStoreName in interface PagingStore

page

public boolean page(ServerMessage message,
           RoutingContext ctx)
             throws Exception

Specified by:

page in interface PagingStore

Throws:

Exception

page

public boolean page(ServerMessage message,
           RoutingContext ctx,
           RouteContextList listCtx)
             throws Exception

Specified by:

page in interface PagingStore

Throws:

Exception

sync

public void sync()
          throws Exception

Specified by:

sync in interface PagingStore

Throws:

Exception

ioSync

public void ioSync()
            throws Exception

Specified by:

ioSync in interface PagingStore

Throws:

Exception

processReload

public void processReload()
                   throws Exception

Specified by:

processReload in interface PagingStore

Throws:

Exception

getPagingManager

public PagingManager getPagingManager()

Specified by:

getPagingManager in interface PagingStore

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

flushExecutors

public void flushExecutors()

Description copied from interface: PagingStore

This is used mostly by tests. We will wait any pending runnable to finish its execution

Specified by:

flushExecutors in interface PagingStore

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

stopPaging

public void stopPaging()

Specified by:

stopPaging in interface PagingStore

startPaging

public boolean startPaging()

Specified by:

startPaging in interface PagingStore

Returns:

true if paging was started, or false if paging was already started before this call

getCurrentPage

public Page getCurrentPage()

Specified by:

getCurrentPage in interface PagingStore

checkPage

public boolean checkPage(int pageNumber)

Specified by:

checkPage in interface PagingStore

createPage

public Page createPage(int pageNumber)
                throws Exception

Specified by:

createPage in interface PagingStore

Throws:

Exception

forceAnotherPage

public void forceAnotherPage()
                      throws Exception

Specified by:

forceAnotherPage in interface PagingStore

Throws:

Exception

depage

public Page depage()
            throws Exception

It returns a Page out of the Page System without reading it. The method calling this method will remove the page and will start reading it outside of any locks. This method could also replace the current file by a new file, and that process is done through acquiring a writeLock on currentPageLock Observation: This method is used internally as part of the regular depage process, but externally is used only on tests, and that's why this method is part of the Testable Interface

Specified by:

depage in interface PagingStore

Throws:

Exception - Note: This should still be part of the interface, even though HornetQ only uses through the

executeRunnableWhenMemoryAvailable

public void executeRunnableWhenMemoryAvailable(Runnable runnable)

Specified by:

executeRunnableWhenMemoryAvailable in interface PagingStore

addSize

public void addSize(int size)

Specified by:

addSize in interface PagingStore

page

protected boolean page(ServerMessage message,
           RoutingContext ctx,
           RouteContextList listCtx,
           boolean sync)
                throws Exception

Throws:

Exception