Package org.apache.activemq.artemis.core.persistence

Interface StorageManager

All Superinterfaces:

ActiveMQComponent, IDGenerator, MapStorageManager

All Known Implementing Classes:

AbstractJournalStorageManager, JDBCJournalStorageManager, JournalStorageManager, NullStorageManager

public interface StorageManager
extends MapStorageManager, IDGenerator, ActiveMQComponent

A StorageManager

Note about IDGEnerator

I've changed StorageManager to extend IDGenerator, because in some places all we needed from the StorageManager was the idGeneration. I couldn't just get the IDGenerator from the inner part because the NullPersistent has its own sequence. So the best was to add the interface and adjust the callers for the method

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	StorageManager.LargeMessageExtension

Method Summary

Modifier and Type	Method	Description
void	addAddressBinding(long tx, AddressInfo addressInfo)
void	addBytesToLargeMessage(SequentialFile appendFile, long messageID, byte[] bytes)
void	addBytesToLargeMessage(SequentialFile file, long messageId, ActiveMQBuffer bytes)
void	addGrouping(GroupBinding groupBinding)
void	addQueueBinding(long tx, Binding binding)
boolean	addToPage(PagingStore store, Message msg, Transaction tx, RouteContextList listCtx)	Write message to page if we are paging.
void	afterCompleteOperations(IOCallback run)
void	afterCompleteOperations(IOCallback run, OperationConsistencyLevel consistencyLevel)
void	afterStoreOperations(IOCallback run)	This is similar to afterComplete, however this only cares about the journal part.
ByteBuffer	allocateDirectBuffer(int size)	AIO has an optimized buffer which has a method to release it instead of the way NIO will release data based on GC.
void	asyncCommit(long txID)
void	clearContext()
default ArtemisCloseable	closeableReadLock()
ArtemisCloseable	closeableReadLock(boolean tryLock)	Read lock the StorageManager.
void	commit(long txID)
void	commit(long txID, boolean lineUpContext)
void	commitBindings(long txID)
void	confirmPendingLargeMessage(long recordID)	Confirms that a large message was finished
void	confirmPendingLargeMessageTX(Transaction transaction, long messageID, long recordID)	Confirms that a large message was finished
LargeServerMessage	createCoreLargeMessage()
LargeServerMessage	createCoreLargeMessage(long id, Message message)	Creates a new LargeServerMessage for the core Protocol with the given id.
default SequentialFile	createFileForLargeMessage(long messageID, boolean durable)
SequentialFile	createFileForLargeMessage(long messageID, StorageManager.LargeMessageExtension extension)	Instantiates a SequentialFile to be used for storing a LargeServerMessage.
void	criticalError(Throwable error)
void	deleteAddressBinding(long tx, long addressBindingID)
void	deleteAddressSetting(SimpleString addressMatch)
void	deleteAddressStatus(long recordID)
void	deleteBridgeConfiguration(String bridgeName)
void	deleteConnector(String connectorName)
void	deleteCursorAcknowledge(long ackID)
void	deleteCursorAcknowledgeTransactional(long txID, long ackID)
void	deleteDivertConfiguration(String divertName)
void	deleteDuplicateID(long recordID)
void	deleteDuplicateIDTransactional(long txID, long recordID)
void	deleteGrouping(long tx, GroupBinding groupBinding)
void	deleteHeuristicCompletion(long id)
void	deleteID(long journalD)
void	deleteIncrementRecord(long txID, long recordID)
void	deleteKeyValuePair(String mapId, String key)
void	deleteLargeMessageBody(LargeServerMessage largeServerMessage)
void	deleteMessage(long messageID)
void	deletePageComplete(long ackID)
void	deletePageCounter(long txID, long recordID)
void	deletePageTransactional(long recordID)
void	deletePendingPageCounter(long txID, long recordID)
void	deleteQueueBinding(long tx, long queueBindingID)
void	deleteQueueStatus(long recordID)
void	deleteRole(String role)
void	deleteSecuritySetting(SimpleString addressMatch)
void	deleteUser(String username)
void	freeDirectBuffer(ByteBuffer buffer)	AIO has an optimized buffer which has a method to release it instead of the way NIO will release data based on GC.
default int	getAllowedPageSize(int pageSize)
Journal	getBindingsJournal()
OperationContext	getContext()	Get the context associated with the thread for later reuse
default SequentialFileFactory	getJournalSequentialFileFactory()
default long	getMaxRecordSize()
Journal	getMessageJournal()
Map<String,PersistedKeyValuePair>	getPersistedKeyValuePairs(String mapId)
Map<String,PersistedRole>	getPersistedRoles()
Map<String,PersistedUser>	getPersistedUsers()
default Set<RemotingConnection>	getUsedConnections()
default long	getWarningRecordSize()
void	injectMonitor(FileStoreMonitor monitor)
default boolean	isReplicated()
void	largeMessageClosed(LargeServerMessage largeServerMessage)
void	lineUpContext()
JournalLoadInformation	loadBindingJournal(List<QueueBindingInfo> queueBindingInfos, List<GroupingInfo> groupingInfos, List<AddressBindingInfo> addressBindingInfos)
default JournalLoadInformation	loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long,QueueBindingInfo> queueInfos, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, Set<Pair<Long,Long>> pendingLargeMessages, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader)
default JournalLoadInformation	loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long,QueueBindingInfo> queueInfos, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, Set<Pair<Long,Long>> pendingLargeMessages, Set<Long> largeMessagesInFolder, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader)
JournalLoadInformation	loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long,QueueBindingInfo> queueInfos, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, Set<Pair<Long,Long>> pendingLargeMessages, Set<Long> largeMessagesInFolder, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader, List<Consumer<RecordInfo>> extraRecordsLoader)
OperationContext	newContext(Executor executor)	It just creates an OperationContext without associating it
OperationContext	newSingleThreadContext()
LargeServerMessage	onLargeMessageCreate(long id, LargeServerMessage largeMessage)	Other protocols may inform the storage manager when a large message was created.
void	pageClosed(SimpleString address, long pageNumber)
void	pageDeleted(SimpleString address, long pageNumber)
void	pageWrite(SimpleString address, PagedMessage message, long pageNumber, boolean storageUp, boolean originallyReplicated)
void	persistIdGenerator()	Closes the IDGenerator persisting the current record ID.
void	prepare(long txID, Xid xid)
List<AbstractPersistedAddressSetting>	recoverAddressSettings()
AbstractPersistedAddressSetting	recoverAddressSettings(SimpleString address)
List<PersistedBridgeConfiguration>	recoverBridgeConfigurations()
List<PersistedConnector>	recoverConnectors()
List<PersistedDivertConfiguration>	recoverDivertConfigurations()
default void	recoverLargeMessagesOnFolder(Set<Long> files)
List<PersistedSecuritySetting>	recoverSecuritySettings()
void	rollback(long txID)
void	rollbackBindings(long txID)
void	setContext(OperationContext context)	Set the context back to the thread
void	startReplication(ReplicationManager replicationManager, PagingManager pagingManager, String nodeID, boolean autoFailBack, long initialReplicationSyncTimeout)
void	stop(boolean ioCriticalError, boolean sendFailover)	Stop this StorageManager
void	stopReplication()	Stops the replication of data from the primary to the backup.
void	storeAcknowledge(long queueID, long messageID)
void	storeAcknowledgeTransactional(long txID, long queueID, long messageID)
void	storeAddressSetting(PersistedAddressSettingJSON addressSetting)
long	storeAddressStatus(long addressID, AddressQueueStatus status)
void	storeBridgeConfiguration(PersistedBridgeConfiguration persistedBridgeConfiguration)
void	storeConnector(PersistedConnector persistedConnector)
void	storeCursorAcknowledge(long queueID, PagePosition position)
void	storeCursorAcknowledgeTransactional(long txID, long queueID, PagePosition position)
void	storeDivertConfiguration(PersistedDivertConfiguration persistedDivertConfiguration)
void	storeDuplicateID(SimpleString address, byte[] duplID, long recordID)
void	storeDuplicateIDTransactional(long txID, SimpleString address, byte[] duplID, long recordID)
long	storeHeuristicCompletion(Xid xid, boolean isCommit)
void	storeID(long journalID, long id)	Stores the id from IDManager.
void	storeKeyValuePair(PersistedKeyValuePair persistedKeyValuePair)
void	storeMessage(Message message)
void	storeMessageTransactional(long txID, Message message)
void	storePageCompleteTransactional(long txID, long queueID, PagePosition position)
long	storePageCounter(long txID, long queueID, long value, long persistentSize)	Store the specificed page counter.
long	storePageCounterInc(long queueID, int add, long size)	Store the specificed page counter increment.
long	storePageCounterInc(long txID, long queueID, int add, long persistentSize)	Store the specificed page counter increment.
void	storePageTransaction(long txID, PageTransactionInfo pageTransaction)
long	storePendingCounter(long queueID, long pageID)
long	storeQueueStatus(long queueID, AddressQueueStatus status)	Store a queue's status.
void	storeReference(long queueID, long messageID, boolean last)
void	storeReferenceTransactional(long txID, long queueID, long messageID)
void	storeRole(PersistedRole persistedRole)
void	storeSecuritySetting(PersistedSecuritySetting persistedRoles)
void	storeUser(PersistedUser persistedUser)
void	updateDeliveryCount(MessageReference ref)
void	updateDuplicateIDTransactional(long txID, SimpleString address, byte[] duplID, long recordID)
void	updatePageTransaction(long txID, PageTransactionInfo pageTransaction, int depage)
void	updateQueueBinding(long tx, Binding binding)
void	updateScheduledDeliveryTime(MessageReference ref)
void	updateScheduledDeliveryTimeTransactional(long txID, MessageReference ref)
void	waitOnOperations()	Block until the operations are done.
boolean	waitOnOperations(long timeout)	Block until the operations are done.
default void	writeLock()
default void	writeUnlock()

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop, isStarted, start, stop

Methods inherited from interface org.apache.activemq.artemis.utils.IDGenerator

generateID, getCurrentID

Methods inherited from interface org.apache.activemq.artemis.core.journal.collections.MapStorageManager

deleteMapRecord, deleteMapRecordTx, storeMapRecord, storeMapRecord

Method Details

getMaxRecordSize

default long getMaxRecordSize()

isReplicated

default boolean isReplicated()

getWarningRecordSize

default long getWarningRecordSize()

recoverLargeMessagesOnFolder

default void recoverLargeMessagesOnFolder(Set<Long> files)
                                   throws Exception

Throws:

Exception

writeLock

default void writeLock()

writeUnlock

default void writeUnlock()

getJournalSequentialFileFactory

default SequentialFileFactory getJournalSequentialFileFactory()

criticalError

void criticalError(Throwable error)

getContext

OperationContext getContext()

Get the context associated with the thread for later reuse

lineUpContext

void lineUpContext()

newContext

OperationContext newContext(Executor executor)

It just creates an OperationContext without associating it

newSingleThreadContext

OperationContext newSingleThreadContext()

setContext

void setContext(OperationContext context)

Set the context back to the thread

stop

void stop(boolean ioCriticalError,
 boolean sendFailover)
   throws Exception

Stop this StorageManager

Parameters:

ioCriticalError - is the server being stopped due to an IO critical error.

sendFailover - this is to send the replication stopping in case of replication.

Throws:

Exception

getUsedConnections

default Set<RemotingConnection> getUsedConnections()

pageClosed

void pageClosed(SimpleString address,
 long pageNumber)

pageDeleted

void pageDeleted(SimpleString address,
 long pageNumber)

pageWrite

void pageWrite(SimpleString address,
 PagedMessage message,
 long pageNumber,
 boolean storageUp,
 boolean originallyReplicated)

afterCompleteOperations

void afterCompleteOperations(IOCallback run)

afterCompleteOperations

void afterCompleteOperations(IOCallback run,
 OperationConsistencyLevel consistencyLevel)

afterStoreOperations

void afterStoreOperations(IOCallback run)

This is similar to afterComplete, however this only cares about the journal part.

waitOnOperations

boolean waitOnOperations(long timeout)
                  throws Exception

Block until the operations are done. Warning: Don't use it inside an ordered executor, otherwise the system may lock up in case of the pools are full

Throws:

Exception

waitOnOperations

void waitOnOperations()
               throws Exception

Block until the operations are done. Warning: Don't use it inside an ordered executor, otherwise the system may lock up in case of the pools are full

Throws:

Exception

allocateDirectBuffer

ByteBuffer allocateDirectBuffer(int size)

AIO has an optimized buffer which has a method to release it instead of the way NIO will release data based on GC. These methods will use that buffer if the inner method supports it

freeDirectBuffer

void freeDirectBuffer(ByteBuffer buffer)

AIO has an optimized buffer which has a method to release it instead of the way NIO will release data based on GC. These methods will use that buffer if the inner method supports it

clearContext

void clearContext()

confirmPendingLargeMessageTX

void confirmPendingLargeMessageTX(Transaction transaction,
 long messageID,
 long recordID)
                           throws Exception

Confirms that a large message was finished

Throws:

Exception

confirmPendingLargeMessage

void confirmPendingLargeMessage(long recordID)
                         throws Exception

Confirms that a large message was finished

Throws:

Exception

storeMessage

void storeMessage(Message message)
           throws Exception

Throws:

Exception

storeReference

void storeReference(long queueID,
 long messageID,
 boolean last)
             throws Exception

Throws:

Exception

deleteMessage

void deleteMessage(long messageID)
            throws Exception

Throws:

Exception

storeAcknowledge

void storeAcknowledge(long queueID,
 long messageID)
               throws Exception

Throws:

Exception

storeCursorAcknowledge

void storeCursorAcknowledge(long queueID,
 PagePosition position)
                     throws Exception

Throws:

Exception

updateDeliveryCount

void updateDeliveryCount(MessageReference ref)
                  throws Exception

Throws:

Exception

updateScheduledDeliveryTime

void updateScheduledDeliveryTime(MessageReference ref)
                          throws Exception

Throws:

Exception

storeDuplicateID

void storeDuplicateID(SimpleString address,
 byte[] duplID,
 long recordID)
               throws Exception

Throws:

Exception

deleteDuplicateID

void deleteDuplicateID(long recordID)
                throws Exception

Throws:

Exception

storeMessageTransactional

void storeMessageTransactional(long txID,
 Message message)
                        throws Exception

Throws:

Exception

storeReferenceTransactional

void storeReferenceTransactional(long txID,
 long queueID,
 long messageID)
                          throws Exception

Throws:

Exception

storeAcknowledgeTransactional

void storeAcknowledgeTransactional(long txID,
 long queueID,
 long messageID)
                            throws Exception

Throws:

Exception

storeCursorAcknowledgeTransactional

void storeCursorAcknowledgeTransactional(long txID,
 long queueID,
 PagePosition position)
                                  throws Exception

Throws:

Exception

deleteCursorAcknowledgeTransactional

void deleteCursorAcknowledgeTransactional(long txID,
 long ackID)
                                   throws Exception

Throws:

Exception

deleteCursorAcknowledge

void deleteCursorAcknowledge(long ackID)
                      throws Exception

Throws:

Exception

storePageCompleteTransactional

void storePageCompleteTransactional(long txID,
 long queueID,
 PagePosition position)
                             throws Exception

Throws:

Exception

deletePageComplete

void deletePageComplete(long ackID)
                 throws Exception

Throws:

Exception

updateScheduledDeliveryTimeTransactional

void updateScheduledDeliveryTimeTransactional(long txID,
 MessageReference ref)
                                       throws Exception

Throws:

Exception

storeDuplicateIDTransactional

void storeDuplicateIDTransactional(long txID,
 SimpleString address,
 byte[] duplID,
 long recordID)
                            throws Exception

Throws:

Exception

updateDuplicateIDTransactional

void updateDuplicateIDTransactional(long txID,
 SimpleString address,
 byte[] duplID,
 long recordID)
                             throws Exception

Throws:

Exception

deleteDuplicateIDTransactional

void deleteDuplicateIDTransactional(long txID,
 long recordID)
                             throws Exception

Throws:

Exception

createCoreLargeMessage

LargeServerMessage createCoreLargeMessage()

createCoreLargeMessage

LargeServerMessage createCoreLargeMessage(long id,
 Message message)
                                   throws Exception

Creates a new LargeServerMessage for the core Protocol with the given id.

Parameters:

message - This is a temporary message that holds the parsed properties. The remoting layer can't create a ServerMessage directly, then this will be replaced.

Returns:

a large message object

Throws:

Exception

onLargeMessageCreate

LargeServerMessage onLargeMessageCreate(long id,
 LargeServerMessage largeMessage)
                                 throws Exception

Other protocols may inform the storage manager when a large message was created.

Throws:

Exception

createFileForLargeMessage

SequentialFile createFileForLargeMessage(long messageID,
 StorageManager.LargeMessageExtension extension)

Instantiates a SequentialFile to be used for storing a LargeServerMessage.

Parameters:

messageID - the id of the message

extension - the extension to add to the file

largeMessageClosed

void largeMessageClosed(LargeServerMessage largeServerMessage)
                 throws ActiveMQException

Throws:

ActiveMQException

deleteLargeMessageBody

void deleteLargeMessageBody(LargeServerMessage largeServerMessage)
                     throws ActiveMQException

Throws:

ActiveMQException

createFileForLargeMessage

default SequentialFile createFileForLargeMessage(long messageID,
 boolean durable)

prepare

void prepare(long txID,
 Xid xid)
      throws Exception

Throws:

Exception

commit

void commit(long txID)
     throws Exception

Throws:

Exception

commit

void commit(long txID,
 boolean lineUpContext)
     throws Exception

Throws:

Exception

asyncCommit

void asyncCommit(long txID)
          throws Exception

Throws:

Exception

rollback

void rollback(long txID)
       throws Exception

Throws:

Exception

rollbackBindings

void rollbackBindings(long txID)
               throws Exception

Throws:

Exception

commitBindings

void commitBindings(long txID)
             throws Exception

Throws:

Exception

storePageTransaction

void storePageTransaction(long txID,
 PageTransactionInfo pageTransaction)
                   throws Exception

Throws:

Exception

updatePageTransaction

void updatePageTransaction(long txID,
 PageTransactionInfo pageTransaction,
 int depage)
                    throws Exception

Throws:

Exception

deletePageTransactional

void deletePageTransactional(long recordID)
                      throws Exception

Throws:

Exception

loadMessageJournal

default JournalLoadInformation loadMessageJournal(PostOffice postOffice,
 PagingManager pagingManager,
 ResourceManager resourceManager,
 Map<Long,QueueBindingInfo> queueInfos,
 Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
 Set<Pair<Long,Long>> pendingLargeMessages,
 List<PageCountPending> pendingNonTXPageCounter,
 JournalLoader journalLoader)
                                           throws Exception

Throws:

Exception

loadMessageJournal

default JournalLoadInformation loadMessageJournal(PostOffice postOffice,
 PagingManager pagingManager,
 ResourceManager resourceManager,
 Map<Long,QueueBindingInfo> queueInfos,
 Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
 Set<Pair<Long,Long>> pendingLargeMessages,
 Set<Long> largeMessagesInFolder,
 List<PageCountPending> pendingNonTXPageCounter,
 JournalLoader journalLoader)
                                           throws Exception

Throws:

Exception

loadMessageJournal

JournalLoadInformation loadMessageJournal(PostOffice postOffice,
 PagingManager pagingManager,
 ResourceManager resourceManager,
 Map<Long,QueueBindingInfo> queueInfos,
 Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
 Set<Pair<Long,Long>> pendingLargeMessages,
 Set<Long> largeMessagesInFolder,
 List<PageCountPending> pendingNonTXPageCounter,
 JournalLoader journalLoader,
 List<Consumer<RecordInfo>> extraRecordsLoader)
                                   throws Exception

Throws:

Exception

storeHeuristicCompletion

long storeHeuristicCompletion(Xid xid,
 boolean isCommit)
                       throws Exception

Throws:

Exception

deleteHeuristicCompletion

void deleteHeuristicCompletion(long id)
                        throws Exception

Throws:

Exception

addQueueBinding

void addQueueBinding(long tx,
 Binding binding)
              throws Exception

Throws:

Exception

updateQueueBinding

void updateQueueBinding(long tx,
 Binding binding)
                 throws Exception

Throws:

Exception

deleteQueueBinding

void deleteQueueBinding(long tx,
 long queueBindingID)
                 throws Exception

Throws:

Exception

storeQueueStatus

long storeQueueStatus(long queueID,
 AddressQueueStatus status)
               throws Exception

Store a queue's status.

Parameters:

queueID - The id of the queue

status - The current status of the queue. (Reserved for future use, ATM we only use this record for PAUSED)

Returns:

the id of the journal

Throws:

Exception

deleteQueueStatus

void deleteQueueStatus(long recordID)
                throws Exception

Throws:

Exception

storeAddressStatus

long storeAddressStatus(long addressID,
 AddressQueueStatus status)
                 throws Exception

Throws:

Exception

deleteAddressStatus

void deleteAddressStatus(long recordID)
                  throws Exception

Throws:

Exception

addAddressBinding

void addAddressBinding(long tx,
 AddressInfo addressInfo)
                throws Exception

Throws:

Exception

deleteAddressBinding

void deleteAddressBinding(long tx,
 long addressBindingID)
                   throws Exception

Throws:

Exception

loadBindingJournal

JournalLoadInformation loadBindingJournal(List<QueueBindingInfo> queueBindingInfos,
 List<GroupingInfo> groupingInfos,
 List<AddressBindingInfo> addressBindingInfos)
                                   throws Exception

Throws:

Exception

addGrouping

void addGrouping(GroupBinding groupBinding)
          throws Exception

Throws:

Exception

deleteGrouping

void deleteGrouping(long tx,
 GroupBinding groupBinding)
             throws Exception

Throws:

Exception

storeAddressSetting

void storeAddressSetting(PersistedAddressSettingJSON addressSetting)
                  throws Exception

Throws:

Exception

deleteAddressSetting

void deleteAddressSetting(SimpleString addressMatch)
                   throws Exception

Throws:

Exception

recoverAddressSettings

List<AbstractPersistedAddressSetting> recoverAddressSettings()
                                                      throws Exception

Throws:

Exception

recoverAddressSettings

AbstractPersistedAddressSetting recoverAddressSettings(SimpleString address)

storeSecuritySetting

void storeSecuritySetting(PersistedSecuritySetting persistedRoles)
                   throws Exception

Throws:

Exception

deleteSecuritySetting

void deleteSecuritySetting(SimpleString addressMatch)
                    throws Exception

Throws:

Exception

recoverSecuritySettings

List<PersistedSecuritySetting> recoverSecuritySettings()
                                                throws Exception

Throws:

Exception

storeDivertConfiguration

void storeDivertConfiguration(PersistedDivertConfiguration persistedDivertConfiguration)
                       throws Exception

Throws:

Exception

deleteDivertConfiguration

void deleteDivertConfiguration(String divertName)
                        throws Exception

Throws:

Exception

recoverDivertConfigurations

List<PersistedDivertConfiguration> recoverDivertConfigurations()

storeBridgeConfiguration

void storeBridgeConfiguration(PersistedBridgeConfiguration persistedBridgeConfiguration)
                       throws Exception

Throws:

Exception

deleteBridgeConfiguration

void deleteBridgeConfiguration(String bridgeName)
                        throws Exception

Throws:

Exception

recoverBridgeConfigurations

List<PersistedBridgeConfiguration> recoverBridgeConfigurations()

storeConnector

void storeConnector(PersistedConnector persistedConnector)
             throws Exception

Throws:

Exception

deleteConnector

void deleteConnector(String connectorName)
              throws Exception

Throws:

Exception

recoverConnectors

List<PersistedConnector> recoverConnectors()

storeUser

void storeUser(PersistedUser persistedUser)
        throws Exception

Throws:

Exception

deleteUser

void deleteUser(String username)
         throws Exception

Throws:

Exception

getPersistedUsers

Map<String,PersistedUser> getPersistedUsers()

storeRole

void storeRole(PersistedRole persistedRole)
        throws Exception

Throws:

Exception

deleteRole

void deleteRole(String role)
         throws Exception

Throws:

Exception

getPersistedRoles

Map<String,PersistedRole> getPersistedRoles()

storeKeyValuePair

void storeKeyValuePair(PersistedKeyValuePair persistedKeyValuePair)
                throws Exception

Throws:

Exception

deleteKeyValuePair

void deleteKeyValuePair(String mapId,
 String key)
                 throws Exception

Throws:

Exception

getPersistedKeyValuePairs

Map<String,PersistedKeyValuePair> getPersistedKeyValuePairs(String mapId)

storePageCounter

long storePageCounter(long txID,
 long queueID,
 long value,
 long persistentSize)
               throws Exception

Store the specificed page counter.

Returns:

The ID with the stored counter

Throws:

Exception

storePendingCounter

long storePendingCounter(long queueID,
 long pageID)
                  throws Exception

Throws:

Exception

deleteIncrementRecord

void deleteIncrementRecord(long txID,
 long recordID)
                    throws Exception

Throws:

Exception

deletePageCounter

void deletePageCounter(long txID,
 long recordID)
                throws Exception

Throws:

Exception

deletePendingPageCounter

void deletePendingPageCounter(long txID,
 long recordID)
                       throws Exception

Throws:

Exception

storePageCounterInc

long storePageCounterInc(long txID,
 long queueID,
 int add,
 long persistentSize)
                  throws Exception

Store the specificed page counter increment.

Returns:

the ID with the increment record

Throws:

Exception

storePageCounterInc

long storePageCounterInc(long queueID,
 int add,
 long size)
                  throws Exception

Store the specificed page counter increment.

Returns:

the ID with the increment record

Throws:

Exception

getBindingsJournal

Journal getBindingsJournal()

getMessageJournal

Journal getMessageJournal()

startReplication

void startReplication(ReplicationManager replicationManager,
 PagingManager pagingManager,
 String nodeID,
 boolean autoFailBack,
 long initialReplicationSyncTimeout)
               throws Exception

Throws:

Exception

addToPage

boolean addToPage(PagingStore store,
 Message msg,
 Transaction tx,
 RouteContextList listCtx)
           throws Exception

Write message to page if we are paging.

Returns:

true if we are paging and have handled the data, false if the data needs to be sent to the journal

Throws:

Exception

stopReplication

void stopReplication()

Stops the replication of data from the primary to the backup.

Typical scenario is a broken connection.

addBytesToLargeMessage

void addBytesToLargeMessage(SequentialFile appendFile,
 long messageID,
 byte[] bytes)
                     throws Exception

Throws:

Exception

addBytesToLargeMessage

void addBytesToLargeMessage(SequentialFile file,
 long messageId,
 ActiveMQBuffer bytes)
                     throws Exception

Throws:

Exception

storeID

void storeID(long journalID,
 long id)
      throws Exception

Stores the id from IDManager.

Throws:

Exception

deleteID

void deleteID(long journalD)
       throws Exception

Throws:

Exception

closeableReadLock

default ArtemisCloseable closeableReadLock()

closeableReadLock

ArtemisCloseable closeableReadLock(boolean tryLock)

Read lock the StorageManager. USE WITH CARE!

The main lock is used to write lock the whole manager when starting replication. Sub-systems, say Paging classes, that use locks of their own AND also write through the StorageManager MUST first read lock the storageManager before taking their own locks. Otherwise, we may dead-lock when starting replication sync.

persistIdGenerator

void persistIdGenerator()

Closes the IDGenerator persisting the current record ID.

Effectively a "pre-stop" method. Necessary due to the "stop"-order at ActiveMQServerImpl

injectMonitor

void injectMonitor(FileStoreMonitor monitor)
            throws Exception

Throws:

Exception

getAllowedPageSize

default int getAllowedPageSize(int pageSize)