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

Class JDBCJournalStorageManager

java.lang.Object

org.apache.activemq.artemis.utils.critical.CriticalComponentImpl

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:

MapStorageManager, StorageManager, ActiveMQComponent, CriticalComponent, 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

ACTIVEMQ_DATA, bindingsFF, journalFF, largeMessagesDirectory, largeMessagesFactory, originalBindingsJournal, originalMessageJournal, replicator

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

bindingsJournal, config, CRITICAL_PATHS, CRITICAL_STOP, CRITICAL_STOP_2, CRITICAL_STORE, dummyCloseable, executorFactory, idGenerator, ioCriticalErrorListener, ioExecutorFactory, journalLoaded, largeMessagesToDelete, mapPersistedAddressSettings, mapPersistedBridgeConfigurations, mapPersistedConnectors, mapPersistedDivertConfigurations, mapPersistedKeyValuePairs, mapPersistedRoles, mapPersistedSecuritySettings, mapPersistedUsers, messageJournal, scheduledExecutorService, started, storageManagerLock, unlockCloseable

Constructor Summary

Constructors

Constructor	Description
JDBCJournalStorageManager(Configuration config, CriticalAnalyzer analyzer, ScheduledExecutorService scheduledExecutorService, ExecutorFactory executorFactory, ExecutorFactory ioExecutorFactory, IOCriticalErrorListener criticalErrorListener)
JDBCJournalStorageManager(Configuration config, CriticalAnalyzer analyzer, ExecutorFactory executorFactory, ExecutorFactory ioExecutorFactory, ScheduledExecutorService scheduledExecutorService)

Method Summary

Modifier and Type	Method	Description
final void	addBytesToLargeMessage(SequentialFile file, long messageId, byte[] bytes)
final void	addBytesToLargeMessage(SequentialFile file, long messageId, ActiveMQBuffer 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.
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)	Stop this StorageManager

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

beforeStart, beforeStop, createCoreLargeMessage, createCoreLargeMessage, createDirectories, createFileForLargeMessage, createMessageJournal, deleteLargeMessageBody, fixJournalFileSize, getAllowedPageSize, getJournalSequentialFileFactory, getUsedConnections, injectMonitor, isReplicated, largeMessageClosed, onLargeMessageCreate, pageClosed, pageDeleted, pageWrite, parseLargeMessage, performCachedLargeMessageDeletes, recoverLargeMessagesOnFolder, startReplication, stop, stopReplication

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

addAddressBinding, addGrouping, addQueueBinding, addToPage, afterCompleteOperations, afterCompleteOperations, afterStoreOperations, asyncCommit, checkInvalidPageTransactions, clearContext, closeableReadLock, commit, commit, commitBindings, confirmPendingLargeMessage, confirmPendingLargeMessageTX, criticalError, deleteAddressBinding, deleteAddressSetting, deleteAddressStatus, deleteBridgeConfiguration, deleteConnector, deleteCursorAcknowledge, deleteCursorAcknowledgeTransactional, deleteDivertConfiguration, deleteDuplicateID, deleteDuplicateIDTransactional, deleteGrouping, deleteHeuristicCompletion, deleteID, deleteIncrementRecord, deleteKeyValuePair, deleteMapRecord, deleteMapRecordTx, deleteMessage, deletePageComplete, deletePageCounter, deletePageTransactional, deletePendingPageCounter, deleteQueueBinding, deleteQueueStatus, deleteRole, deleteSecuritySetting, deleteUser, generateID, getBindingsJournal, getConfig, getContext, getCurrentID, getIDGenerator, getMaxRecordSize, getMessageJournal, getPersistedKeyValuePairs, getPersistedRoles, getPersistedUsers, getWarningRecordSize, isStarted, lineUpContext, loadBindingJournal, loadInternalOnly, loadMessageJournal, newAddressBindingEncoding, newContext, newQueueBindingEncoding, newQueueStatusEncoding, newSecurityRecord, newSingleThreadContext, persistIdGenerator, prepare, recoverAddressSettings, recoverAddressSettings, recoverBridgeConfigurations, recoverConnectors, recoverDivertConfigurations, recoverSecuritySettings, rollback, rollbackBindings, setContext, start, storeAcknowledge, storeAcknowledgeTransactional, storeAddressSetting, storeAddressStatus, storeBridgeConfiguration, storeConnector, storeCursorAcknowledge, storeCursorAcknowledgeTransactional, storeDivertConfiguration, storeDuplicateID, storeDuplicateIDTransactional, storeHeuristicCompletion, storeID, storeKeyValuePair, storeMapRecord, storeMapRecord, storeMessage, storeMessageTransactional, storePageCompleteTransactional, storePageCounter, storePageCounterInc, storePageCounterInc, storePageTransaction, storePendingCounter, storeQueueStatus, storeReference, storeReferenceTransactional, storeRole, storeSecuritySetting, storeUser, updateDeliveryCount, updateDuplicateIDTransactional, updatePageTransaction, updateQueueBinding, updateScheduledDeliveryTime, updateScheduledDeliveryTimeTransactional, waitOnOperations, waitOnOperations, writeLock, writeUnlock

Methods inherited from class org.apache.activemq.artemis.utils.critical.CriticalComponentImpl

checkExpiration, getCriticalAnalyzer, measureCritical

Methods inherited from class java.lang.Object

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

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

asyncStop

Methods inherited from interface org.apache.activemq.artemis.core.persistence.StorageManager

closeableReadLock, createFileForLargeMessage, loadMessageJournal, loadMessageJournal

Constructor Details

JDBCJournalStorageManager

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

JDBCJournalStorageManager

public JDBCJournalStorageManager(Configuration config,
 CriticalAnalyzer analyzer,
 ScheduledExecutorService scheduledExecutorService,
 ExecutorFactory executorFactory,
 ExecutorFactory ioExecutorFactory,
 IOCriticalErrorListener criticalErrorListener)

Method Details

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

addBytesToLargeMessage

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

Specified by:

addBytesToLargeMessage in interface StorageManager

Overrides:

addBytesToLargeMessage in class JournalStorageManager

Throws:

Exception

addBytesToLargeMessage

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

Specified by:

addBytesToLargeMessage in interface StorageManager

Overrides:

addBytesToLargeMessage in class JournalStorageManager

Throws:

Exception

stop

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

Description copied from interface: StorageManager

Stop this StorageManager

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