Class NullStorageManager
java.lang.Object
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager
- All Implemented Interfaces:
MapStorageManager,StorageManager,ActiveMQComponent,IDGenerator
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.activemq.artemis.core.persistence.StorageManager
StorageManager.LargeMessageExtension -
Constructor Summary
ConstructorsConstructorDescriptionNullStorageManager(int nextId) NullStorageManager(IOCriticalErrorListener ioCriticalErrorListener) -
Method Summary
Modifier and TypeMethodDescriptionvoidaddAddressBinding(long tx, AddressInfo addressInfo) voidaddBytesToLargeMessage(SequentialFile appendFile, long messageID, byte[] bytes) voidaddBytesToLargeMessage(SequentialFile file, long messageId, ActiveMQBuffer bytes) voidaddGrouping(GroupBinding groupBinding) voidaddQueueBinding(long tx, Binding binding) booleanaddToPage(PagingStore store, Message msg, Transaction tx, RouteContextList listCtx) Write message to page if we are paging.voidvoidafterCompleteOperations(IOCallback run, OperationConsistencyLevel consistencyLevel) voidThis is similar to afterComplete, however this only cares about the journal part.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.voidasyncCommit(long txID) voidcloseableReadLock(boolean tryLock) Read lock the StorageManager.voidcommit(long txID) voidcommit(long txID, boolean lineUpContext) voidcommitBindings(long txID) voidconfirmPendingLargeMessage(long recordID) Confirms that a large message was finishedvoidconfirmPendingLargeMessageTX(Transaction transaction, long messageID, long recordID) Confirms that a large message was finishedcreateCoreLargeMessage(long id, Message message) Creates a new LargeServerMessage for the core Protocol with the given id.createFileForLargeMessage(long messageID, StorageManager.LargeMessageExtension extension) Instantiates a SequentialFile to be used for storing aLargeServerMessage.voidcriticalError(Throwable error) voiddeleteAddressBinding(long tx, long addressBindingID) voiddeleteAddressSetting(SimpleString addressMatch) voiddeleteAddressStatus(long recordID) voiddeleteBridgeConfiguration(String bridgeName) voiddeleteConnector(String connectorName) voiddeleteCursorAcknowledge(long ackID) voiddeleteCursorAcknowledgeTransactional(long txID, long ackID) voiddeleteDivertConfiguration(String divertName) voiddeleteDuplicateID(long recordID) voiddeleteDuplicateIDTransactional(long txID, long recordID) voiddeleteGrouping(long tx, GroupBinding groupBinding) voiddeleteHeuristicCompletion(long txID) voiddeleteID(long journalD) voiddeleteIncrementRecord(long txID, long recordID) voiddeleteKeyValuePair(String mapId, String key) voiddeleteLargeMessageBody(LargeServerMessage largeServerMessage) voiddeleteMapRecord(long id, boolean sync) voiddeleteMapRecordTx(long txid, long id) voiddeleteMessage(long messageID) voiddeletePageComplete(long ackID) voiddeletePageCounter(long txID, long recordID) voiddeletePageTransactional(long recordID) voiddeletePendingPageCounter(long txID, long recordID) voiddeleteQueueBinding(long tx, long queueBindingID) voiddeleteQueueStatus(long recordID) voiddeleteRole(String role) voiddeleteSecuritySetting(SimpleString addressMatch) voiddeleteUser(String username) voidfreeDirectBuffer(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.longGet the context associated with the thread for later reuselonggetPersistedKeyValuePairs(String mapId) voidinjectMonitor(FileStoreMonitor monitor) booleanvoidlargeMessageClosed(LargeServerMessage largeServerMessage) voidloadBindingJournal(List<QueueBindingInfo> queueBindingInfos, List<GroupingInfo> groupingInfos, List<AddressBindingInfo> addressBindingInfos) 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> storedLargeMessages, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader, List<Consumer<RecordInfo>> extraLoaders) newContext(Executor executor) It just creates an OperationContext without associating itonLargeMessageCreate(long id, LargeServerMessage largeMessage) Other protocols may inform the storage manager when a large message was created.voidpageClosed(SimpleString storeName, long pageNumber) voidpageDeleted(SimpleString storeName, long pageNumber) voidpageWrite(SimpleString address, PagedMessage message, long pageNumber, boolean lineup, boolean originallyReplicated) voidCloses theIDGeneratorpersisting the current record ID.voidrecoverAddressSettings(SimpleString address) voidrollback(long txID) voidrollbackBindings(long txID) voidsetContext(OperationContext context) Set the context back to the threadsetContextSupplier(Supplier<OperationContext> contextSupplier) protected voidsetNextId(long id) voidstart()voidstartReplication(ReplicationManager replicationManager, PagingManager pagingManager, String nodeID, boolean autoFailBack, long initialReplicationSyncTimeout) voidstop()voidstop(boolean ioCriticalError, boolean sendFailover) Stop thisStorageManagervoidStops the replication of data from the primary to the backup.voidstoreAcknowledge(long queueID, long messageID) voidstoreAcknowledgeTransactional(long txID, long queueID, long messageiD) voidstoreAddressSetting(PersistedAddressSettingJSON addressSetting) longstoreAddressStatus(long addressID, AddressQueueStatus status) voidstoreBridgeConfiguration(PersistedBridgeConfiguration persistedBridgeConfiguration) voidstoreConnector(PersistedConnector persistedConnector) voidstoreCursorAcknowledge(long queueID, PagePosition position) voidstoreCursorAcknowledgeTransactional(long txID, long queueID, PagePosition position) voidstoreDivertConfiguration(PersistedDivertConfiguration persistedDivertConfiguration) voidstoreDuplicateID(SimpleString address, byte[] duplID, long recordID) voidstoreDuplicateIDTransactional(long txID, SimpleString address, byte[] duplID, long recordID) longstoreHeuristicCompletion(Xid xid, boolean isCommit) voidstoreID(long journalID, long id) Stores the id from IDManager.voidstoreKeyValuePair(PersistedKeyValuePair persistedKeyValuePair) voidstoreMapRecord(long id, byte recordType, Persister persister, Object record, boolean sync) voidstoreMapRecord(long id, byte recordType, Persister persister, Object record, boolean sync, IOCompletion completionCallback) voidstoreMessage(Message message) voidstoreMessageTransactional(long txID, Message message) voidstorePageCompleteTransactional(long txID, long queueID, PagePosition position) longstorePageCounter(long txID, long queueID, long value, long size) Store the specificed page counter.longstorePageCounterInc(long queueID, int add, long size) Store the specificed page counter increment.longstorePageCounterInc(long txID, long queueID, int add, long size) Store the specificed page counter increment.voidstorePageTransaction(long txID, PageTransactionInfo pageTransaction) longstorePendingCounter(long queueID, long pageID) longstoreQueueStatus(long queueID, AddressQueueStatus status) Store a queue's status.voidstoreReference(long queueID, long messageID, boolean last) voidstoreReferenceTransactional(long txID, long queueID, long messageID) voidstoreRole(PersistedRole persistedRole) voidstoreSecuritySetting(PersistedSecuritySetting persistedRoles) voidstoreUser(PersistedUser persistedUser) voidvoidupdateDuplicateIDTransactional(long txID, SimpleString address, byte[] duplID, long recordID) voidupdatePageTransaction(long txID, PageTransactionInfo pageTransaction, int depage) voidupdateQueueBinding(long tx, Binding binding) voidvoidupdateScheduledDeliveryTimeTransactional(long txID, MessageReference ref) voidBlock until the operations are done.booleanwaitOnOperations(long timeout) Block until the operations are done.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent
asyncStopMethods inherited from interface org.apache.activemq.artemis.core.persistence.StorageManager
closeableReadLock, createFileForLargeMessage, getAllowedPageSize, getJournalSequentialFileFactory, getMaxRecordSize, getUsedConnections, getWarningRecordSize, isReplicated, loadMessageJournal, loadMessageJournal, recoverLargeMessagesOnFolder, writeLock, writeUnlock
-
Constructor Details
-
NullStorageManager
-
NullStorageManager
public NullStorageManager() -
NullStorageManager
public NullStorageManager(int nextId)
-
-
Method Details
-
recoverAddressSettings
- Specified by:
recoverAddressSettingsin interfaceStorageManager
-
closeableReadLock
Description copied from interface:StorageManagerRead 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.
- Specified by:
closeableReadLockin interfaceStorageManager
-
setNextId
protected void setNextId(long id) -
criticalError
- Specified by:
criticalErrorin interfaceStorageManager
-
storeQueueStatus
Description copied from interface:StorageManagerStore a queue's status.- Specified by:
storeQueueStatusin interfaceStorageManager- Parameters:
queueID- The id of the queuestatus- 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
-
updateQueueBinding
- Specified by:
updateQueueBindingin interfaceStorageManager- Throws:
Exception
-
deleteQueueStatus
- Specified by:
deleteQueueStatusin interfaceStorageManager- Throws:
Exception
-
storeAddressStatus
- Specified by:
storeAddressStatusin interfaceStorageManager- Throws:
Exception
-
deleteAddressStatus
- Specified by:
deleteAddressStatusin interfaceStorageManager- Throws:
Exception
-
injectMonitor
- Specified by:
injectMonitorin interfaceStorageManager- Throws:
Exception
-
deleteQueueBinding
- Specified by:
deleteQueueBindingin interfaceStorageManager- Throws:
Exception
-
addAddressBinding
- Specified by:
addAddressBindingin interfaceStorageManager- Throws:
Exception
-
deleteAddressBinding
- Specified by:
deleteAddressBindingin interfaceStorageManager- Throws:
Exception
-
commit
- Specified by:
commitin interfaceStorageManager- Throws:
Exception
-
asyncCommit
public void asyncCommit(long txID) - Specified by:
asyncCommitin interfaceStorageManager
-
loadBindingJournal
public JournalLoadInformation loadBindingJournal(List<QueueBindingInfo> queueBindingInfos, List<GroupingInfo> groupingInfos, List<AddressBindingInfo> addressBindingInfos) throws Exception - Specified by:
loadBindingJournalin interfaceStorageManager- Throws:
Exception
-
prepare
- Specified by:
preparein interfaceStorageManager- Throws:
Exception
-
rollback
- Specified by:
rollbackin interfaceStorageManager- Throws:
Exception
-
rollbackBindings
- Specified by:
rollbackBindingsin interfaceStorageManager- Throws:
Exception
-
commitBindings
- Specified by:
commitBindingsin interfaceStorageManager- Throws:
Exception
-
storeReference
- Specified by:
storeReferencein interfaceStorageManager- Throws:
Exception
-
storeReferenceTransactional
- Specified by:
storeReferenceTransactionalin interfaceStorageManager- Throws:
Exception
-
storeAcknowledge
- Specified by:
storeAcknowledgein interfaceStorageManager- Throws:
Exception
-
storeAcknowledgeTransactional
- Specified by:
storeAcknowledgeTransactionalin interfaceStorageManager- Throws:
Exception
-
deleteMessage
- Specified by:
deleteMessagein interfaceStorageManager- Throws:
Exception
-
storeMessage
- Specified by:
storeMessagein interfaceStorageManager- Throws:
Exception
-
storeMessageTransactional
- Specified by:
storeMessageTransactionalin interfaceStorageManager- Throws:
Exception
-
updateScheduledDeliveryTime
- Specified by:
updateScheduledDeliveryTimein interfaceStorageManager- Throws:
Exception
-
updateScheduledDeliveryTimeTransactional
public void updateScheduledDeliveryTimeTransactional(long txID, MessageReference ref) throws Exception - Specified by:
updateScheduledDeliveryTimeTransactionalin interfaceStorageManager- Throws:
Exception
-
storePageTransaction
- Specified by:
storePageTransactionin interfaceStorageManager- Throws:
Exception
-
updateDeliveryCount
- Specified by:
updateDeliveryCountin interfaceStorageManager- Throws:
Exception
-
storeDuplicateID
- Specified by:
storeDuplicateIDin interfaceStorageManager- Throws:
Exception
-
storeDuplicateIDTransactional
public void storeDuplicateIDTransactional(long txID, SimpleString address, byte[] duplID, long recordID) throws Exception - Specified by:
storeDuplicateIDTransactionalin interfaceStorageManager- Throws:
Exception
-
updateDuplicateIDTransactional
public void updateDuplicateIDTransactional(long txID, SimpleString address, byte[] duplID, long recordID) throws Exception - Specified by:
updateDuplicateIDTransactionalin interfaceStorageManager- Throws:
Exception
-
storeHeuristicCompletion
- Specified by:
storeHeuristicCompletionin interfaceStorageManager- Throws:
Exception
-
deleteHeuristicCompletion
- Specified by:
deleteHeuristicCompletionin interfaceStorageManager- Throws:
Exception
-
addQueueBinding
- Specified by:
addQueueBindingin interfaceStorageManager- Throws:
Exception
-
createCoreLargeMessage
- Specified by:
createCoreLargeMessagein interfaceStorageManager
-
createCoreLargeMessage
Description copied from interface:StorageManagerCreates a new LargeServerMessage for the core Protocol with the given id.- Specified by:
createCoreLargeMessagein interfaceStorageManagermessage- 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
-
onLargeMessageCreate
public LargeServerMessage onLargeMessageCreate(long id, LargeServerMessage largeMessage) throws Exception Description copied from interface:StorageManagerOther protocols may inform the storage manager when a large message was created.- Specified by:
onLargeMessageCreatein interfaceStorageManager- Throws:
Exception
-
generateID
public long generateID()- Specified by:
generateIDin interfaceIDGenerator
-
getCurrentID
public long getCurrentID()- Specified by:
getCurrentIDin interfaceIDGenerator
-
start
- Specified by:
startin interfaceActiveMQComponent- Throws:
Exception
-
stop
- Specified by:
stopin interfaceActiveMQComponent- Throws:
Exception
-
isStarted
public boolean isStarted()- Specified by:
isStartedin interfaceActiveMQComponent
-
loadMessageJournal
public JournalLoadInformation loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long, QueueBindingInfo> queueInfos, Map<SimpleString, throws ExceptionList<Pair<byte[], Long>>> duplicateIDMap, Set<Pair<Long, Long>> pendingLargeMessages, Set<Long> storedLargeMessages, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader, List<Consumer<RecordInfo>> extraLoaders) - Specified by:
loadMessageJournalin interfaceStorageManager- Throws:
Exception
-
deleteDuplicateIDTransactional
- Specified by:
deleteDuplicateIDTransactionalin interfaceStorageManager- Throws:
Exception
-
deleteDuplicateID
- Specified by:
deleteDuplicateIDin interfaceStorageManager- Throws:
Exception
-
pageClosed
- Specified by:
pageClosedin interfaceStorageManager
-
pageDeleted
- Specified by:
pageDeletedin interfaceStorageManager
-
pageWrite
public void pageWrite(SimpleString address, PagedMessage message, long pageNumber, boolean lineup, boolean originallyReplicated) - Specified by:
pageWritein interfaceStorageManager
-
addGrouping
- Specified by:
addGroupingin interfaceStorageManager- Throws:
Exception
-
deleteGrouping
- Specified by:
deleteGroupingin interfaceStorageManager- Throws:
Exception
-
waitOnOperations
Description copied from interface:StorageManagerBlock 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- Specified by:
waitOnOperationsin interfaceStorageManager- Throws:
Exception
-
afterCompleteOperations
- Specified by:
afterCompleteOperationsin interfaceStorageManager
-
afterCompleteOperations
- Specified by:
afterCompleteOperationsin interfaceStorageManager
-
afterStoreOperations
Description copied from interface:StorageManagerThis is similar to afterComplete, however this only cares about the journal part.- Specified by:
afterStoreOperationsin interfaceStorageManager
-
waitOnOperations
Description copied from interface:StorageManagerBlock 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- Specified by:
waitOnOperationsin interfaceStorageManager- Throws:
Exception
-
setContextSupplier
-
getContext
Description copied from interface:StorageManagerGet the context associated with the thread for later reuse- Specified by:
getContextin interfaceStorageManager
-
newContext
Description copied from interface:StorageManagerIt just creates an OperationContext without associating it- Specified by:
newContextin interfaceStorageManager
-
newSingleThreadContext
- Specified by:
newSingleThreadContextin interfaceStorageManager
-
setContext
Description copied from interface:StorageManagerSet the context back to the thread- Specified by:
setContextin interfaceStorageManager
-
clearContext
public void clearContext()- Specified by:
clearContextin interfaceStorageManager
-
recoverAddressSettings
- Specified by:
recoverAddressSettingsin interfaceStorageManager- Throws:
Exception
-
storeAddressSetting
- Specified by:
storeAddressSettingin interfaceStorageManager- Throws:
Exception
-
recoverSecuritySettings
- Specified by:
recoverSecuritySettingsin interfaceStorageManager- Throws:
Exception
-
storeDivertConfiguration
public void storeDivertConfiguration(PersistedDivertConfiguration persistedDivertConfiguration) throws Exception - Specified by:
storeDivertConfigurationin interfaceStorageManager- Throws:
Exception
-
deleteDivertConfiguration
- Specified by:
deleteDivertConfigurationin interfaceStorageManager- Throws:
Exception
-
recoverDivertConfigurations
- Specified by:
recoverDivertConfigurationsin interfaceStorageManager
-
storeBridgeConfiguration
public void storeBridgeConfiguration(PersistedBridgeConfiguration persistedBridgeConfiguration) throws Exception - Specified by:
storeBridgeConfigurationin interfaceStorageManager- Throws:
Exception
-
deleteBridgeConfiguration
- Specified by:
deleteBridgeConfigurationin interfaceStorageManager- Throws:
Exception
-
recoverBridgeConfigurations
- Specified by:
recoverBridgeConfigurationsin interfaceStorageManager
-
storeConnector
- Specified by:
storeConnectorin interfaceStorageManager- Throws:
Exception
-
deleteConnector
- Specified by:
deleteConnectorin interfaceStorageManager- Throws:
Exception
-
recoverConnectors
- Specified by:
recoverConnectorsin interfaceStorageManager
-
storeUser
- Specified by:
storeUserin interfaceStorageManager- Throws:
Exception
-
deleteUser
- Specified by:
deleteUserin interfaceStorageManager- Throws:
Exception
-
getPersistedUsers
- Specified by:
getPersistedUsersin interfaceStorageManager
-
storeRole
- Specified by:
storeRolein interfaceStorageManager- Throws:
Exception
-
deleteRole
- Specified by:
deleteRolein interfaceStorageManager- Throws:
Exception
-
getPersistedRoles
- Specified by:
getPersistedRolesin interfaceStorageManager
-
storeKeyValuePair
- Specified by:
storeKeyValuePairin interfaceStorageManager- Throws:
Exception
-
deleteKeyValuePair
- Specified by:
deleteKeyValuePairin interfaceStorageManager- Throws:
Exception
-
getPersistedKeyValuePairs
- Specified by:
getPersistedKeyValuePairsin interfaceStorageManager
-
storeSecuritySetting
- Specified by:
storeSecuritySettingin interfaceStorageManager- Throws:
Exception
-
deleteAddressSetting
- Specified by:
deleteAddressSettingin interfaceStorageManager- Throws:
Exception
-
deleteSecuritySetting
- Specified by:
deleteSecuritySettingin interfaceStorageManager- Throws:
Exception
-
deletePageTransactional
- Specified by:
deletePageTransactionalin interfaceStorageManager- Throws:
Exception
-
updatePageTransaction
public void updatePageTransaction(long txID, PageTransactionInfo pageTransaction, int depage) throws Exception - Specified by:
updatePageTransactionin interfaceStorageManager- Throws:
Exception
-
storeCursorAcknowledge
- Specified by:
storeCursorAcknowledgein interfaceStorageManager
-
storeCursorAcknowledgeTransactional
- Specified by:
storeCursorAcknowledgeTransactionalin interfaceStorageManager
-
deleteCursorAcknowledgeTransactional
- Specified by:
deleteCursorAcknowledgeTransactionalin interfaceStorageManager- Throws:
Exception
-
deleteCursorAcknowledge
- Specified by:
deleteCursorAcknowledgein interfaceStorageManager- Throws:
Exception
-
storePageCompleteTransactional
public void storePageCompleteTransactional(long txID, long queueID, PagePosition position) throws Exception - Specified by:
storePageCompleteTransactionalin interfaceStorageManager- Throws:
Exception
-
deletePageComplete
- Specified by:
deletePageCompletein interfaceStorageManager- Throws:
Exception
-
storePageCounter
Description copied from interface:StorageManagerStore the specificed page counter.- Specified by:
storePageCounterin interfaceStorageManager- Returns:
- The ID with the stored counter
- Throws:
Exception
-
storePendingCounter
- Specified by:
storePendingCounterin interfaceStorageManager- Throws:
Exception
-
deleteIncrementRecord
- Specified by:
deleteIncrementRecordin interfaceStorageManager- Throws:
Exception
-
deletePageCounter
- Specified by:
deletePageCounterin interfaceStorageManager- Throws:
Exception
-
deletePendingPageCounter
- Specified by:
deletePendingPageCounterin interfaceStorageManager- Throws:
Exception
-
storePageCounterInc
Description copied from interface:StorageManagerStore the specificed page counter increment.- Specified by:
storePageCounterIncin interfaceStorageManager- Returns:
- the ID with the increment record
- Throws:
Exception
-
storePageCounterInc
Description copied from interface:StorageManagerStore the specificed page counter increment.- Specified by:
storePageCounterIncin interfaceStorageManager- Returns:
- the ID with the increment record
- Throws:
Exception
-
commit
- Specified by:
commitin interfaceStorageManager- Throws:
Exception
-
lineUpContext
public void lineUpContext()- Specified by:
lineUpContextin interfaceStorageManager
-
confirmPendingLargeMessageTX
public void confirmPendingLargeMessageTX(Transaction transaction, long messageID, long recordID) throws Exception Description copied from interface:StorageManagerConfirms that a large message was finished- Specified by:
confirmPendingLargeMessageTXin interfaceStorageManager- Throws:
Exception
-
confirmPendingLargeMessage
Description copied from interface:StorageManagerConfirms that a large message was finished- Specified by:
confirmPendingLargeMessagein interfaceStorageManager- Throws:
Exception
-
stop
Description copied from interface:StorageManagerStop thisStorageManager- Specified by:
stopin interfaceStorageManager- 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
-
getBindingsJournal
- Specified by:
getBindingsJournalin interfaceStorageManager
-
getMessageJournal
- Specified by:
getMessageJournalin interfaceStorageManager
-
startReplication
public void startReplication(ReplicationManager replicationManager, PagingManager pagingManager, String nodeID, boolean autoFailBack, long initialReplicationSyncTimeout) throws Exception - Specified by:
startReplicationin interfaceStorageManager- Throws:
Exception
-
deleteLargeMessageBody
- Specified by:
deleteLargeMessageBodyin interfaceStorageManager- Throws:
ActiveMQException
-
largeMessageClosed
- Specified by:
largeMessageClosedin interfaceStorageManager- Throws:
ActiveMQException
-
addToPage
public boolean addToPage(PagingStore store, Message msg, Transaction tx, RouteContextList listCtx) throws Exception Description copied from interface:StorageManagerWrite message to page if we are paging.- Specified by:
addToPagein interfaceStorageManager- Returns:
trueif we are paging and have handled the data,falseif the data needs to be sent to the journal- Throws:
Exception
-
stopReplication
public void stopReplication()Description copied from interface:StorageManagerStops the replication of data from the primary to the backup.Typical scenario is a broken connection.
- Specified by:
stopReplicationin interfaceStorageManager
-
createFileForLargeMessage
public SequentialFile createFileForLargeMessage(long messageID, StorageManager.LargeMessageExtension extension) Description copied from interface:StorageManagerInstantiates a SequentialFile to be used for storing aLargeServerMessage.- Specified by:
createFileForLargeMessagein interfaceStorageManager- Parameters:
messageID- the id of the messageextension- the extension to add to the file
-
addBytesToLargeMessage
public void addBytesToLargeMessage(SequentialFile appendFile, long messageID, byte[] bytes) throws Exception - Specified by:
addBytesToLargeMessagein interfaceStorageManager- Throws:
Exception
-
addBytesToLargeMessage
public void addBytesToLargeMessage(SequentialFile file, long messageId, ActiveMQBuffer bytes) throws Exception - Specified by:
addBytesToLargeMessagein interfaceStorageManager- Throws:
Exception
-
allocateDirectBuffer
Description copied from interface:StorageManagerAIO 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- Specified by:
allocateDirectBufferin interfaceStorageManager
-
freeDirectBuffer
Description copied from interface:StorageManagerAIO 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- Specified by:
freeDirectBufferin interfaceStorageManager
-
storeID
Description copied from interface:StorageManagerStores the id from IDManager.- Specified by:
storeIDin interfaceStorageManager- Throws:
Exception
-
persistIdGenerator
public void persistIdGenerator()Description copied from interface:StorageManagerCloses theIDGeneratorpersisting the current record ID.Effectively a "pre-stop" method. Necessary due to the "stop"-order at
ActiveMQServerImpl- Specified by:
persistIdGeneratorin interfaceStorageManager
-
deleteID
- Specified by:
deleteIDin interfaceStorageManager- Throws:
Exception
-
storeMapRecord
public void storeMapRecord(long id, byte recordType, Persister persister, Object record, boolean sync, IOCompletion completionCallback) throws Exception - Specified by:
storeMapRecordin interfaceMapStorageManager- Throws:
Exception
-
storeMapRecord
public void storeMapRecord(long id, byte recordType, Persister persister, Object record, boolean sync) throws Exception - Specified by:
storeMapRecordin interfaceMapStorageManager- Throws:
Exception
-
deleteMapRecord
- Specified by:
deleteMapRecordin interfaceMapStorageManager- Throws:
Exception
-
deleteMapRecordTx
- Specified by:
deleteMapRecordTxin interfaceMapStorageManager- Throws:
Exception
-