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

Class PageCursorProviderImpl

java.lang.Object

org.apache.activemq.artemis.core.paging.cursor.impl.PageCursorProviderImpl

All Implemented Interfaces:

PageCursorProvider

public class PageCursorProviderImpl
extends Object
implements PageCursorProvider

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	cleanupEnabled
protected final PagingStore	pagingStore
protected boolean	rebuildDone
protected final AtomicInteger	scheduledCleanup	As an optimization, avoid subsequent schedules as they are unnecessary
protected final StorageManager	storageManager

Constructor Summary

Constructors

Constructor	Description
PageCursorProviderImpl(PagingStore pagingStore, StorageManager storageManager)

Method Summary

Modifier and Type	Method	Description
void	checkClearPageLimit()
protected void	cleanup()
protected void	cleanupComplete(List<PageSubscription> cursorList)
void	close(PageSubscription cursor)
void	counterRebuildDone()
void	counterRebuildStarted()
void	counterSnapshot()
PageSubscription	createSubscription(long cursorID, Filter filter, boolean persistent)
void	disableCleanup()
protected void	finishCleanup(List<Page> depagedPages)
void	flushExecutors()
void	forEachSubscription(Consumer<PageSubscription> consumer)
protected long	getNumberOfMessagesOnSubscriptions()
PageSubscription	getSubscription(long cursorID)
boolean	isRebuildDone()
PagedReference	newReference(PagedMessage msg, PageSubscription subscription)
protected void	onDeletePage(Page deletedPage)
void	onPageModeCleared()	Delete everything associated with any queue on this address.
void	processReload()
void	resumeCleanup()
Future<Boolean>	scheduleCleanup()
void	stop()
protected void	storeBookmark(List<PageSubscription> cursorList, Page currentPage)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

scheduledCleanup

protected final AtomicInteger scheduledCleanup

As an optimization, avoid subsequent schedules as they are unnecessary

cleanupEnabled

protected volatile boolean cleanupEnabled

rebuildDone

protected volatile boolean rebuildDone

pagingStore

protected final PagingStore pagingStore

storageManager

protected final StorageManager storageManager

Constructor Details

PageCursorProviderImpl

public PageCursorProviderImpl(PagingStore pagingStore,
 StorageManager storageManager)

Method Details

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 persistence

forEachSubscription

public void forEachSubscription(Consumer<PageSubscription> consumer)

Specified by:

forEachSubscription in interface PageCursorProvider

newReference

public PagedReference newReference(PagedMessage msg,
 PageSubscription subscription)

Specified by:

newReference 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

counterSnapshot

public void counterSnapshot()

Specified by:

counterSnapshot 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 Future<Boolean> scheduleCleanup()

Specified by:

scheduleCleanup in interface PageCursorProvider

onPageModeCleared

public void onPageModeCleared()

Delete everything associated with any queue on this address. This is to be called when the address is about to be released from paging. Hence the PagingStore will be holding a write lock, meaning no messages are going to be paged at this time. So, we shouldn't lock anything after this method, to avoid dead locks between the writeLock and any synchronization with the CursorProvider.

Specified by:

onPageModeCleared in interface PageCursorProvider

disableCleanup

public void disableCleanup()

Specified by:

disableCleanup in interface PageCursorProvider

resumeCleanup

public void resumeCleanup()

Specified by:

resumeCleanup in interface PageCursorProvider

getNumberOfMessagesOnSubscriptions

protected long getNumberOfMessagesOnSubscriptions()

checkClearPageLimit

public void checkClearPageLimit()

Specified by:

checkClearPageLimit in interface PageCursorProvider

cleanup

protected void cleanup()

cleanupComplete

protected void cleanupComplete(List<PageSubscription> cursorList)
                        throws Exception

Throws:

Exception

finishCleanup

protected void finishCleanup(List<Page> depagedPages)

onDeletePage

protected void onDeletePage(Page deletedPage)
                     throws Exception

Throws:

Exception

storeBookmark

protected void storeBookmark(List<PageSubscription> cursorList,
 Page currentPage)
                      throws Exception

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object

counterRebuildStarted

public void counterRebuildStarted()

Specified by:

counterRebuildStarted in interface PageCursorProvider

counterRebuildDone

public void counterRebuildDone()

Specified by:

counterRebuildDone in interface PageCursorProvider

isRebuildDone

public boolean isRebuildDone()

Specified by:

isRebuildDone in interface PageCursorProvider