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

Class PageCounterRebuildManager

java.lang.Object

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

All Implemented Interfaces:

Runnable

public class PageCounterRebuildManager
extends Object
implements Runnable

this class will copy current data from the Subscriptions, count messages while the server is already active performing other activity

Constructor Summary

Constructors

Constructor	Description
PageCounterRebuildManager(PagingManager pagingManager, PagingStore store, Map<Long,PageTransactionInfo> transactions, Set<Long> storedLargeMessages, AtomicLong minPageTXIDFound)

Method Summary

Modifier and Type	Method	Description
void	rebuild()
void	run()

Methods inherited from class java.lang.Object

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

Constructor Details

PageCounterRebuildManager

public PageCounterRebuildManager(PagingManager pagingManager,
 PagingStore store,
 Map<Long,PageTransactionInfo> transactions,
 Set<Long> storedLargeMessages,
 AtomicLong minPageTXIDFound)

Method Details

run

public void run()

Specified by:

run in interface Runnable

rebuild

public void rebuild()
             throws Exception

Throws:

Exception