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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddACK(PagePosition posACK)protected voidcheckDone()voiddecrementPendingTX()PageCachegetCache()PagePositiongetCompleteInfo()longgetPageId()intgetPendingTx()PageCachegetValidCache()voidincrementPendingTX()booleanisAck(PagePosition position)booleanisDone()booleanisPendingDelete()booleanisRemoved(PagePosition pos)voidloadACK(PagePosition posACK)voidremove(PagePosition position)voidsetCompleteInfo(PagePosition completePage)voidsetPendingDelete()StringtoString()
-
-
-
Method Detail
-
isAck
public boolean isAck(PagePosition position)
-
setCompleteInfo
public void setCompleteInfo(PagePosition completePage)
- Parameters:
completePage-
-
getCompleteInfo
public PagePosition getCompleteInfo()
-
isDone
public boolean isDone()
- Specified by:
isDonein interfaceConsumedPage
-
isPendingDelete
public boolean isPendingDelete()
-
setPendingDelete
public void setPendingDelete()
-
getPageId
public long getPageId()
- Specified by:
getPageIdin interfaceConsumedPage- 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()
-
-