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

Class JournalStorageManager

java.lang.Object

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

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

All Implemented Interfaces:

StorageManager, ActiveMQComponent, IDGenerator

Direct Known Subclasses:

JDBCJournalStorageManager

public class JournalStorageManager
extends AbstractJournalStorageManager

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.activemq.artemis.core.persistence.impl.journal.AbstractJournalStorageManager

AbstractJournalStorageManager.JournalContent

Nested classes/interfaces inherited from interface org.apache.activemq.artemis.core.persistence.StorageManager

StorageManager.LargeMessageExtension

Field Summary

Fields

Modifier and Type	Field and Description
protected String	largeMessagesDirectory

Fields inherited from class org.apache.activemq.artemis.core.persistence.impl.journal.AbstractJournalStorageManager

bindingsJournal, config, executorFactory, idGenerator, ioExecutors, journalLoaded, largeMessagesToDelete, mapPersistedAddressSettings, mapPersistedRoles, messageJournal, pageMaxConcurrentIO, perfBlastPages, scheduledExecutorService, started, storageManagerLock

Constructor Summary

Constructors

Constructor and Description
JournalStorageManager(Configuration config, ExecutorFactory executorFactory, ExecutorFactory ioExecutors)
JournalStorageManager(Configuration config, ExecutorFactory executorFactory, ExecutorFactory ioExecutors, IOCriticalErrorListener criticalErrorListener)
JournalStorageManager(Configuration config, ExecutorFactory executorFactory, ScheduledExecutorService scheduledExecutorService, ExecutorFactory ioExecutors)
JournalStorageManager(Configuration config, ExecutorFactory executorFactory, ScheduledExecutorService scheduledExecutorService, ExecutorFactory ioExecutors, IOCriticalErrorListener criticalErrorListener)

Method Summary

Modifier and Type	Method and Description
void	addBytesToLargeMessage(SequentialFile file, long messageId, byte[] bytes)
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.
protected void	beforeStart()
protected void	beforeStop()
protected SequentialFile	createFileForLargeMessage(long messageID, boolean durable)
SequentialFile	createFileForLargeMessage(long messageID, StorageManager.LargeMessageExtension extension) Instantiates a SequentialFile to be used for storing a LargeServerMessage.
LargeServerMessage	createLargeMessage()
LargeServerMessage	createLargeMessage(long id, MessageInternal message) Creates a new LargeMessage with the given id.
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.
protected void	init(Configuration config, IOCriticalErrorListener criticalErrorListener) Called during initialization.
void	injectMonitor(FileStoreMonitor monitor)
boolean	isReplicated()
void	pageClosed(SimpleString storeName, int pageNumber)
void	pageDeleted(SimpleString storeName, int pageNumber)
void	pageWrite(PagedMessage message, int pageNumber)
protected LargeServerMessage	parseLargeMessage(Map<Long,ServerMessage> messages, ActiveMQBuffer buff)
protected void	performCachedLargeMessageDeletes() Assumption is that this is only called with a writeLock on the StorageManager.
void	startReplication(ReplicationManager replicationManager, PagingManager pagingManager, String nodeID, boolean autoFailBack, long initialReplicationSyncTimeout)
void	stop()
void	stop(boolean ioCriticalError, boolean sendFailover)
void	stopReplication() Stops replication by resetting replication-related fields to their 'unreplicated' state.
long	storePendingLargeMessage(long messageID, long recordID)

Methods inherited from class org.apache.activemq.artemis.core.persistence.impl.journal.AbstractJournalStorageManager

addGrouping, addQueueBinding, addToPage, afterCompleteOperations, afterPageRead, afterStoreOperations, beforePageRead, clearContext, commit, commit, commitBindings, confirmLargeMessage, confirmPendingLargeMessage, confirmPendingLargeMessageTX, criticalError, deleteAddressSetting, deleteCursorAcknowledge, deleteCursorAcknowledgeTransactional, deleteDuplicateID, deleteDuplicateIDTransactional, deleteGrouping, deleteHeuristicCompletion, deleteID, deleteIncrementRecord, deleteMessage, deletePageComplete, deletePageCounter, deletePageTransactional, deletePendingPageCounter, deleteQueueBinding, deleteQueueStatus, deleteSecurityRoles, generateID, getBindingsJournal, getContext, getCurrentID, getIDGenerator, getMessageJournal, isStarted, lineUpContext, loadBindingJournal, loadInternalOnly, loadMessageJournal, md5, newBindingEncoding, newContext, newQueueStatusEncoding, newSecurityRecord, newSingleThreadContext, persistIdGenerator, prepare, readLock, readUnLock, recoverAddressSettings, recoverPersistedRoles, rollback, rollbackBindings, setContext, start, storeAcknowledge, storeAcknowledgeTransactional, storeAddressSetting, storeCursorAcknowledge, storeCursorAcknowledgeTransactional, storeDuplicateID, storeDuplicateIDTransactional, storeHeuristicCompletion, storeID, storeMessage, storeMessageTransactional, storePageCompleteTransactional, storePageCounter, storePageCounterInc, storePageCounterInc, storePageTransaction, storePendingCounter, storeQueueStatus, storeReference, storeReferenceTransactional, storeSecurityRoles, updateDeliveryCount, updateDuplicateIDTransactional, updatePageTransaction, updatePageTransaction, updateScheduledDeliveryTime, updateScheduledDeliveryTimeTransactional, waitOnOperations, waitOnOperations

Methods inherited from class java.lang.Object

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

Field Detail

largeMessagesDirectory

protected String largeMessagesDirectory

Constructor Detail

JournalStorageManager

public JournalStorageManager(Configuration config,
                             ExecutorFactory executorFactory,
                             ScheduledExecutorService scheduledExecutorService,
                             ExecutorFactory ioExecutors)

JournalStorageManager

public JournalStorageManager(Configuration config,
                             ExecutorFactory executorFactory,
                             ExecutorFactory ioExecutors)

JournalStorageManager

public JournalStorageManager(Configuration config,
                             ExecutorFactory executorFactory,
                             ScheduledExecutorService scheduledExecutorService,
                             ExecutorFactory ioExecutors,
                             IOCriticalErrorListener criticalErrorListener)

JournalStorageManager

public JournalStorageManager(Configuration config,
                             ExecutorFactory executorFactory,
                             ExecutorFactory ioExecutors,
                             IOCriticalErrorListener criticalErrorListener)

Method Detail

init

protected void init(Configuration config,
                    IOCriticalErrorListener criticalErrorListener)

Description copied from class: AbstractJournalStorageManager

Called during initialization. Used by implementations to setup Journals, Stores etc...

Specified by:

init in class AbstractJournalStorageManager

beforeStart

protected void beforeStart()
                    throws Exception

Specified by:

beforeStart in class AbstractJournalStorageManager

Throws:

Exception

beforeStop

protected void beforeStop()
                   throws Exception

Specified by:

beforeStop in class AbstractJournalStorageManager

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Overrides:

stop in class AbstractJournalStorageManager

Throws:

Exception

isReplicated

public boolean isReplicated()

stop

public void stop(boolean ioCriticalError,
                 boolean sendFailover)
          throws Exception

Specified by:

stop in interface StorageManager

Overrides:

stop in class AbstractJournalStorageManager

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

performCachedLargeMessageDeletes

protected void performCachedLargeMessageDeletes()

Assumption is that this is only called with a writeLock on the StorageManager.

Specified by:

performCachedLargeMessageDeletes in class AbstractJournalStorageManager

createFileForLargeMessage

protected SequentialFile createFileForLargeMessage(long messageID,
                                                   boolean durable)

parseLargeMessage

protected LargeServerMessage parseLargeMessage(Map<Long,ServerMessage> messages,
                                               ActiveMQBuffer buff)
                                        throws Exception

Specified by:

parseLargeMessage in class AbstractJournalStorageManager

Throws:

Exception

pageClosed

public void pageClosed(SimpleString storeName,
                       int pageNumber)

pageDeleted

public void pageDeleted(SimpleString storeName,
                        int pageNumber)

pageWrite

public void pageWrite(PagedMessage message,
                      int pageNumber)

allocateDirectBuffer

public ByteBuffer allocateDirectBuffer(int size)

Description copied from interface: StorageManager

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

public void freeDirectBuffer(ByteBuffer buffer)

Description copied from interface: StorageManager

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

storePendingLargeMessage

public long storePendingLargeMessage(long messageID,
                                     long recordID)
                              throws Exception

Throws:

Exception

createLargeMessage

public LargeServerMessage createLargeMessage()

createLargeMessage

public LargeServerMessage createLargeMessage(long id,
                                             MessageInternal message)
                                      throws Exception

Description copied from interface: StorageManager

Creates a new LargeMessage with the given id.

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

createFileForLargeMessage

public SequentialFile createFileForLargeMessage(long messageID,
                                                StorageManager.LargeMessageExtension extension)

Description copied from interface: StorageManager

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

Returns:

startReplication

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

Throws:

Exception

See Also:

startReplication(org.apache.activemq.artemis.core.replication.ReplicationManager, org.apache.activemq.artemis.core.paging.PagingManager, String, boolean, long)

stopReplication

public void stopReplication()

Stops replication by resetting replication-related fields to their 'unreplicated' state.

addBytesToLargeMessage

public final void addBytesToLargeMessage(SequentialFile file,
                                         long messageId,
                                         byte[] bytes)
                                  throws Exception

Throws:

Exception

injectMonitor

public void injectMonitor(FileStoreMonitor monitor)
                   throws Exception

Throws:

Exception