org.apache.activemq.artemis.core.persistence.impl.journal

Class BatchingIDGenerator

java.lang.Object

org.apache.activemq.artemis.core.persistence.impl.journal.BatchingIDGenerator

All Implemented Interfaces:

org.apache.activemq.artemis.utils.IDGenerator

public final class BatchingIDGenerator
extends Object
implements org.apache.activemq.artemis.utils.IDGenerator

An ID generator that allocates a batch of IDs of size checkpointSize and records the ID in the journal only when starting a new batch.

See Also:

IDGenerator

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	BatchingIDGenerator.IDCounterEncoding

Constructor Summary

Constructors

Constructor and Description
BatchingIDGenerator(long start, long checkpointSize, StorageManager storageManager)

Method Summary

Modifier and Type	Method and Description
void	cleanup() A method to cleanup old records after started
static org.apache.activemq.artemis.core.journal.EncodingSupport	createIDEncodingSupport(long id)
void	forceNextID(long nextID)
long	generateID()
long	getCurrentID()
void	loadState(long journalID, org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
void	persistCurrentID()

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchingIDGenerator

public BatchingIDGenerator(long start,
                           long checkpointSize,
                           StorageManager storageManager)

Method Detail

persistCurrentID

public void persistCurrentID()

cleanup

public void cleanup()

A method to cleanup old records after started

loadState

public void loadState(long journalID,
                      org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)

forceNextID

public void forceNextID(long nextID)

generateID

public long generateID()

Specified by:

generateID in interface org.apache.activemq.artemis.utils.IDGenerator

getCurrentID

public long getCurrentID()

Specified by:

getCurrentID in interface org.apache.activemq.artemis.utils.IDGenerator

createIDEncodingSupport

public static org.apache.activemq.artemis.core.journal.EncodingSupport createIDEncodingSupport(long id)