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

Class JDBCJournalStorageManager

java.lang.Object

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

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

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

All Implemented Interfaces:

StorageManager, ActiveMQComponent, IDGenerator

public class JDBCJournalStorageManager
extends JournalStorageManager

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 inherited from class org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager

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
JDBCJournalStorageManager(Configuration config, ExecutorFactory executorFactory, ExecutorFactory ioExecutorFactory, ScheduledExecutorService scheduledExecutorService)
JDBCJournalStorageManager(Configuration config, ScheduledExecutorService scheduledExecutorService, ExecutorFactory executorFactory, ExecutorFactory ioExecutorFactory, IOCriticalErrorListener criticalErrorListener)

Method Summary

Modifier and Type	Method and Description
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	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	stop(boolean ioCriticalError, boolean sendFailover)

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

addBytesToLargeMessage, beforeStart, beforeStop, createFileForLargeMessage, createFileForLargeMessage, createLargeMessage, createLargeMessage, injectMonitor, isReplicated, pageClosed, pageDeleted, pageWrite, parseLargeMessage, performCachedLargeMessageDeletes, startReplication, stop, stopReplication, storePendingLargeMessage

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

Constructor Detail

JDBCJournalStorageManager

public JDBCJournalStorageManager(Configuration config,
                                 ExecutorFactory executorFactory,
                                 ExecutorFactory ioExecutorFactory,
                                 ScheduledExecutorService scheduledExecutorService)

JDBCJournalStorageManager

public JDBCJournalStorageManager(Configuration config,
                                 ScheduledExecutorService scheduledExecutorService,
                                 ExecutorFactory executorFactory,
                                 ExecutorFactory ioExecutorFactory,
                                 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...

Overrides:

init in class JournalStorageManager

stop

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

Specified by:

stop in interface StorageManager

Overrides:

stop in class JournalStorageManager

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

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

Specified by:

allocateDirectBuffer in interface StorageManager

Overrides:

allocateDirectBuffer in class JournalStorageManager

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

Specified by:

freeDirectBuffer in interface StorageManager

Overrides:

freeDirectBuffer in class JournalStorageManager