org.hornetq.core.paging.cursor.impl

Class PageSubscriptionCounterImpl

java.lang.Object

org.hornetq.core.paging.cursor.impl.PageSubscriptionCounterImpl

All Implemented Interfaces:

PageSubscriptionCounter

public class PageSubscriptionCounterImpl
extends Object
implements PageSubscriptionCounter

This class will encapsulate the persistent counters for the PagingSubscription

Author:

clebertsuconic

Constructor Summary

Constructors

Constructor and Description
PageSubscriptionCounterImpl(StorageManager storage, PageSubscription subscription, Executor executor, boolean persistent, long subscriptionID)

Method Summary

Methods

Modifier and Type	Method and Description
void	addInc(long id, int variance)
void	applyIncrement(Transaction tx, long recordID1, int add) This method will install the prepared TXs
protected void	cleanup() This method should always be called from a single threaded executor
void	delete()
void	delete(Transaction tx)
long	getValue()
void	increment(Transaction tx, int add)
void	incrementProcessed(long id, int add)
void	loadInc(long id, int add)
void	loadValue(long recordID1, long value1)
void	processReload() This will process the reload
void	setPersistent(boolean persistent) used on testing only

Methods inherited from class java.lang.Object

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

Constructor Detail

PageSubscriptionCounterImpl

public PageSubscriptionCounterImpl(StorageManager storage,
                           PageSubscription subscription,
                           Executor executor,
                           boolean persistent,
                           long subscriptionID)

Method Detail

getValue

public long getValue()

Specified by:

getValue in interface PageSubscriptionCounter

increment

public void increment(Transaction tx,
             int add)
               throws Exception

Specified by:

increment in interface PageSubscriptionCounter

Throws:

Exception

applyIncrement

public void applyIncrement(Transaction tx,
                  long recordID1,
                  int add)

This method will install the prepared TXs

Specified by:

applyIncrement in interface PageSubscriptionCounter

Parameters:

tx -

recordID1 -

add -

loadValue

public void loadValue(long recordID1,
             long value1)

Specified by:

loadValue in interface PageSubscriptionCounter

incrementProcessed

public void incrementProcessed(long id,
                      int add)

delete

public void delete()
            throws Exception

Specified by:

delete in interface PageSubscriptionCounter

Throws:

Exception

delete

public void delete(Transaction tx)
            throws Exception

Specified by:

delete in interface PageSubscriptionCounter

Throws:

Exception

loadInc

public void loadInc(long id,
           int add)

Specified by:

loadInc in interface PageSubscriptionCounter

processReload

public void processReload()

Description copied from interface: PageSubscriptionCounter

This will process the reload

Specified by:

processReload in interface PageSubscriptionCounter

addInc

public void addInc(long id,
          int variance)

Specified by:

addInc in interface PageSubscriptionCounter

setPersistent

public void setPersistent(boolean persistent)

used on testing only

cleanup

protected void cleanup()

This method should always be called from a single threaded executor