org.hornetq.core.paging.cursor

Interface PageSubscription

All Known Implementing Classes:

PageSubscriptionImpl

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	close()
void	confirmPosition(PagePosition ref)
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()
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)
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	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()

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 pageStore.isPaging()

iterator

LinkedListIterator<PagedReference> iterator()

close

void close()
           throws Exception

Throws:

Exception

scheduleCleanupCheck

void scheduleCleanupCheck()

cleanupEntries

void cleanupEntries(boolean completeDelete)
                    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 -

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)

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

Parameters:

position -

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:

minPage -

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: