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

Class PageSubscriptionImpl.PageCursorInfo

java.lang.Object

org.apache.activemq.artemis.core.paging.cursor.impl.PageSubscriptionImpl.PageCursorInfo

All Implemented Interfaces:

ConsumedPage

Enclosing class:

PageSubscriptionImpl

public final class PageSubscriptionImpl.PageCursorInfo
extends Object
implements ConsumedPage

This will hold information about the pending ACKs towards a page.

This instance will be released as soon as the entire page is consumed, releasing the memory at that point The ref counts are increased also when a message is ignored for any reason.

Method Summary

Modifier and Type	Method and Description
void	addACK(PagePosition posACK)
protected void	checkDone()
void	decrementPendingTX()
PageCache	getCache()
PagePosition	getCompleteInfo()
long	getPageId()
int	getPendingTx()
PageCache	getValidCache()
void	incrementPendingTX()
boolean	isAck(PagePosition position)
boolean	isDone()
boolean	isPendingDelete()
boolean	isRemoved(PagePosition pos)
void	loadACK(PagePosition posACK)
void	remove(PagePosition position)
void	setCompleteInfo(PagePosition completePage)
void	setPendingDelete()
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

isAck

public boolean isAck(PagePosition position)

toString

public String toString()

Overrides:

toString in class Object

setCompleteInfo

public void setCompleteInfo(PagePosition completePage)

Parameters:

completePage -

getCompleteInfo

public PagePosition getCompleteInfo()

isDone

public boolean isDone()

Specified by:

isDone in interface ConsumedPage

isPendingDelete

public boolean isPendingDelete()

setPendingDelete

public void setPendingDelete()

getPageId

public long getPageId()

Specified by:

getPageId in interface ConsumedPage

Returns:

the pageId

incrementPendingTX

public void incrementPendingTX()

decrementPendingTX

public void decrementPendingTX()

isRemoved

public boolean isRemoved(PagePosition pos)

remove

public void remove(PagePosition position)

addACK

public void addACK(PagePosition posACK)

loadACK

public void loadACK(PagePosition posACK)

checkDone

protected void checkDone()

getValidCache

public PageCache getValidCache()

getCache

public PageCache getCache()

Returns:

the cache

getPendingTx

public int getPendingTx()