org.hornetq.core.paging.cursor.impl

Class PageSubscriptionImpl

java.lang.Object

org.hornetq.core.paging.cursor.impl.PageSubscriptionImpl

All Implemented Interfaces:

PageSubscription

public class PageSubscriptionImpl
extends Object
implements PageSubscription

A PageCursorImpl A page cursor will always store its

Author:

Clebert Suconic

Constructor Summary

Constructors

Constructor and Description
PageSubscriptionImpl(PageCursorProvider cursorProvider, PagingStore pageStore, StorageManager store, Executor executor, Filter filter, long cursorId, boolean persistent)

Method Summary

Methods

Modifier and Type	Method and Description
void	ack(PagedReference reference)
void	ackTx(Transaction tx, PagedReference reference)
void	addPendingDelivery(PagePosition position)
void	bookmark(PagePosition position)
void	cleanupEntries(boolean completeDelete) It will cleanup all the records for completed pages
void	close() All the data associated with the cursor should go away here
void	confirmPosition(PagePosition position)
void	confirmPosition(Transaction tx, PagePosition position)
void	disableAutoCleanup()
void	enableAutoCleanup()
void	flushExecutors() wait all the scheduled runnables to finish their current execution
PageSubscriptionCounter	getCounter()
Executor	getExecutor()
long	getFirstPage()
long	getId()
long	getMessageCount()
PagingStore	getPagingStore()
PageCursorProvider	getProvider()
Queue	getQueue()
boolean	isComplete(long page)
boolean	isPaging() Used as a delegate method to pageStore.isPaging()
boolean	isPersistent()
LinkedListIterator<PagedReference>	iterator()
void	lateDeliveryRollback(PagePosition position)
protected boolean	match(ServerMessage message)
void	positionIgnored(PagePosition position) To be called when the cursor decided to ignore a position.
void	printDebug()
void	printDebug(String msg)
void	processReload()
PagedMessage	queryMessage(PagePosition pos) To be used to requery the reference case the Garbage Collection removed it from the PagedReference as it's using WeakReferences
void	redeliver(PagePosition position) To be used on redeliveries
void	reloadACK(PagePosition position) Theres no need to synchronize this method as it's only called from journal load on startup
void	reloadPreparedACK(Transaction tx, PagePosition position) To be used to avoid a redelivery of a prepared ACK after load
void	scheduleCleanupCheck()
void	setQueue(Queue queue)
void	stop()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

PageSubscriptionImpl

public PageSubscriptionImpl(PageCursorProvider cursorProvider,
                    PagingStore pageStore,
                    StorageManager store,
                    Executor executor,
                    Filter filter,
                    long cursorId,
                    boolean persistent)

Method Detail

getPagingStore

public PagingStore getPagingStore()

Specified by:

getPagingStore in interface PageSubscription

getQueue

public Queue getQueue()

Specified by:

getQueue in interface PageSubscription

isPaging

public boolean isPaging()

Description copied from interface: PageSubscription

Used as a delegate method to pageStore.isPaging()

Specified by:

isPaging in interface PageSubscription

setQueue

public void setQueue(Queue queue)

Specified by:

setQueue in interface PageSubscription

disableAutoCleanup

public void disableAutoCleanup()

Specified by:

disableAutoCleanup in interface PageSubscription

enableAutoCleanup

public void enableAutoCleanup()

Specified by:

enableAutoCleanup in interface PageSubscription

getProvider

public PageCursorProvider getProvider()

bookmark

public void bookmark(PagePosition position)
              throws Exception

Specified by:

bookmark in interface PageSubscription

Throws:

Exception

getMessageCount

public long getMessageCount()

Specified by:

getMessageCount in interface PageSubscription

getCounter

public PageSubscriptionCounter getCounter()

Specified by:

getCounter in interface PageSubscription

scheduleCleanupCheck

public void scheduleCleanupCheck()

Specified by:

scheduleCleanupCheck in interface PageSubscription

cleanupEntries

public void cleanupEntries(boolean completeDelete)
                    throws Exception

It will cleanup all the records for completed pages

Specified by:

cleanupEntries in interface PageSubscription

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object

iterator

public LinkedListIterator<PagedReference> iterator()

Specified by:

iterator in interface PageSubscription

confirmPosition

public void confirmPosition(Transaction tx,
                   PagePosition position)
                     throws Exception

Specified by:

confirmPosition in interface PageSubscription

Throws:

Exception

ackTx

public void ackTx(Transaction tx,
         PagedReference reference)
           throws Exception

Specified by:

ackTx in interface PageSubscription

Throws:

Exception

ack

public void ack(PagedReference reference)
         throws Exception

Specified by:

ack in interface PageSubscription

Throws:

Exception

confirmPosition

public void confirmPosition(PagePosition position)
                     throws Exception

Specified by:

confirmPosition in interface PageSubscription

Throws:

Exception

getFirstPage

public long getFirstPage()

Specified by:

getFirstPage in interface PageSubscription

Returns:

the first page in use or MAX_LONG if none is in use

addPendingDelivery

public void addPendingDelivery(PagePosition position)

Specified by:

addPendingDelivery in interface PageSubscription

redeliver

public void redeliver(PagePosition position)

Description copied from interface: PageSubscription

To be used on redeliveries

Specified by:

redeliver in interface PageSubscription

queryMessage

public PagedMessage queryMessage(PagePosition pos)

Description copied from interface: PageSubscription

To be used to requery the reference case the Garbage Collection removed it from the PagedReference as it's using WeakReferences

Specified by:

queryMessage in interface PageSubscription

Returns:

reloadACK

public void reloadACK(PagePosition position)

Theres no need to synchronize this method as it's only called from journal load on startup

Specified by:

reloadACK in interface PageSubscription

reloadPreparedACK

public void reloadPreparedACK(Transaction tx,
                     PagePosition position)

Description copied from interface: PageSubscription

To be used to avoid a redelivery of a prepared ACK after load

Specified by:

reloadPreparedACK in interface PageSubscription

positionIgnored

public void positionIgnored(PagePosition position)

Description copied from interface: PageSubscription

To be called when the cursor decided to ignore a position.

Specified by:

positionIgnored in interface PageSubscription

lateDeliveryRollback

public void lateDeliveryRollback(PagePosition position)

Specified by:

lateDeliveryRollback in interface PageSubscription

isComplete

public boolean isComplete(long page)

Specified by:

isComplete in interface PageSubscription

Returns:

close

public void close()
           throws Exception

All the data associated with the cursor should go away here

Specified by:

close in interface PageSubscription

Throws:

Exception

getId

public long getId()

Specified by:

getId in interface PageSubscription

isPersistent

public boolean isPersistent()

Specified by:

isPersistent in interface PageSubscription

processReload

public void processReload()
                   throws Exception

Specified by:

processReload in interface PageSubscription

Throws:

Exception

flushExecutors

public void flushExecutors()

Description copied from interface: PageSubscription

wait all the scheduled runnables to finish their current execution

Specified by:

flushExecutors in interface PageSubscription

stop

public void stop()

Specified by:

stop in interface PageSubscription

printDebug

public void printDebug()

Specified by:

printDebug in interface PageSubscription

printDebug

public void printDebug(String msg)

getExecutor

public Executor getExecutor()

Specified by:

getExecutor in interface PageSubscription

Returns:

match

protected boolean match(ServerMessage message)