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

Interface PageSubscriptionCounter

All Known Implementing Classes:

BasePagingCounter, PageSubscriptionCounterImpl

public interface PageSubscriptionCounter

Method Summary

Modifier and Type	Method	Description
void	applyIncrementOnTX(Transaction tx, int add, long persistentSize)
void	delete()
void	delete(Transaction tx)
void	finishRebuild()
long	getPersistentSize()
long	getPersistentSizeAdded()
long	getValue()
long	getValueAdded()
void	increment(Transaction tx, int add, long persistentSize)
boolean	isRebuilding()
void	loadInc(long recordInd, int add, long persistentSize)
void	loadValue(long recordValueID, long value, long persistentSize)
void	markRebuilding()
void	processReload()	This will process the reload
PageSubscriptionCounter	setSubscription(PageSubscription subscription)
void	snapshot()

Method Details

getValueAdded

long getValueAdded()

getValue

long getValue()

getPersistentSizeAdded

long getPersistentSizeAdded()

getPersistentSize

long getPersistentSize()

increment

void increment(Transaction tx,
 int add,
 long persistentSize)
        throws Exception

Throws:

Exception

loadValue

void loadValue(long recordValueID,
 long value,
 long persistentSize)

loadInc

void loadInc(long recordInd,
 int add,
 long persistentSize)

applyIncrementOnTX

void applyIncrementOnTX(Transaction tx,
 int add,
 long persistentSize)

markRebuilding

void markRebuilding()

finishRebuild

void finishRebuild()

isRebuilding

boolean isRebuilding()

processReload

void processReload()

This will process the reload

delete

void delete()
     throws Exception

Throws:

Exception

snapshot

void snapshot()

delete

void delete(Transaction tx)
     throws Exception

Throws:

Exception

setSubscription

PageSubscriptionCounter setSubscription(PageSubscription subscription)