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

Interface PageSubscriptionCounter

All Known Implementing Classes:

PageSubscriptionCounterImpl

public interface PageSubscriptionCounter

Method Summary

Modifier and Type	Method and Description
void	addInc(long id, int variance, long size)
void	applyIncrementOnTX(Transaction tx, long recordID, int add, long persistentSize)
void	cleanupNonTXCounters(long pageID)
void	delete()
void	delete(Transaction tx)
long	getPersistentSize()
long	getPersistentSizeAdded()
long	getValue()
long	getValueAdded()
void	increment(Transaction tx, int add, long persistentSize)
void	loadInc(long recordInd, int add, long persistentSize)
void	loadValue(long recordValueID, long value, long persistentSize)
void	pendingCounter(Page page, int increment, long persistentSize)
void	processReload() This will process the reload

Method Detail

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,
                        long recordID,
                        int add,
                        long persistentSize)

processReload

void processReload()

This will process the reload

addInc

void addInc(long id,
            int variance,
            long size)

Parameters:

id -

variance -

delete

void delete()
     throws Exception

Throws:

Exception

pendingCounter

void pendingCounter(Page page,
                    int increment,
                    long persistentSize)
             throws Exception

Throws:

Exception

delete

void delete(Transaction tx)
     throws Exception

Throws:

Exception

cleanupNonTXCounters

void cleanupNonTXCounters(long pageID)
                   throws Exception

Throws:

Exception