org.hornetq.core.paging.cursor

Interface PageSubscription

public interface PageSubscription

A PageCursor

Author:

Clebert Suconic

Method Summary

Methods

Modifier and Type	Method and Description
void	ack(PagedReference ref)
void	ackTx(Transaction tx, PagedReference position)
void	addPendingDelivery(PagePosition position)
void	bookmark(PagePosition position)
void	cleanupEntries(boolean completeDelete)
void	confirmPosition(PagePosition ref)
void	confirmPosition(Transaction tx, PagePosition position)
void	destroy()
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()
Queue	getQueue()
boolean	isComplete(long page)
boolean	isPaging() Used as a delegate method to PagingStore.isPaging()
boolean	isPersistent()
LinkedListIterator<PagedReference>	iterator()
void	lateDeliveryRollback(PagePosition position)
void	notEmpty() This is a callback to inform the PageSubscription that something was routed, so the empty flag can be cleared
void	onDeletePage(Page deletedPage)
void	onPageModeCleared(Transaction tx)
void	positionIgnored(PagePosition position) To be called when the cursor decided to ignore a position.
void	printDebug()
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)
void	reloadPageCompletion(PagePosition position)
void	reloadPageInfo(long pageNr)
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()

Method Detail

getPagingStore

PagingStore getPagingStore()

stop

void stop()

notEmpty

void notEmpty()

This is a callback to inform the PageSubscription that something was routed, so the empty flag can be cleared

bookmark

void bookmark(PagePosition position)
              throws Exception

Throws:

Exception

getCounter

PageSubscriptionCounter getCounter()

getMessageCount

long getMessageCount()

getId

long getId()

isPersistent

boolean isPersistent()

isPaging

boolean isPaging()

Used as a delegate method to PagingStore.isPaging()

iterator

LinkedListIterator<PagedReference> iterator()

destroy

void destroy()
             throws Exception

Throws:

Exception

scheduleCleanupCheck

void scheduleCleanupCheck()

cleanupEntries

void cleanupEntries(boolean completeDelete)
                    throws Exception

Throws:

Exception

onPageModeCleared

void onPageModeCleared(Transaction tx)
                       throws Exception

Throws:

Exception

disableAutoCleanup

void disableAutoCleanup()

enableAutoCleanup

void enableAutoCleanup()

ack

void ack(PagedReference ref)
         throws Exception

Throws:

Exception

confirmPosition

void confirmPosition(PagePosition ref)
                     throws Exception

Throws:

Exception

ackTx

void ackTx(Transaction tx,
         PagedReference position)
           throws Exception

Throws:

Exception

confirmPosition

void confirmPosition(Transaction tx,
                   PagePosition position)
                     throws Exception

Throws:

Exception

getFirstPage

long getFirstPage()

Returns:

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

reloadACK

void reloadACK(PagePosition position)

Parameters:

position -

reloadPageCompletion

void reloadPageCompletion(PagePosition position)
                          throws Exception

Throws:

Exception

reloadPageInfo

void reloadPageInfo(long pageNr)

positionIgnored

void positionIgnored(PagePosition position)

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

Parameters:

position -

lateDeliveryRollback

void lateDeliveryRollback(PagePosition position)

reloadPreparedACK

void reloadPreparedACK(Transaction tx,
                     PagePosition position)
                       throws HornetQException

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

Parameters:

position -

Throws:

HornetQException

processReload

void processReload()
                   throws Exception

Throws:

Exception

addPendingDelivery

void addPendingDelivery(PagePosition position)

redeliver

void redeliver(PagePosition position)

To be used on redeliveries

Parameters:

position -

printDebug

void printDebug()

isComplete

boolean isComplete(long page)

Parameters:

page -

Returns:

flushExecutors

void flushExecutors()

wait all the scheduled runnables to finish their current execution

setQueue

void setQueue(Queue queue)

getQueue

Queue getQueue()

queryMessage

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

Parameters:

pos -

Returns:

getExecutor

Executor getExecutor()

Returns:

executor used by the PageSubscription

onDeletePage

void onDeletePage(Page deletedPage)
                  throws Exception

Parameters:

deletedPage -

Throws:

Exception