public class JDBCJournalStorageManager extends JournalStorageManager
AbstractJournalStorageManager.JournalContent
StorageManager.LargeMessageExtension
largeMessagesDirectory
bindingsJournal, config, idGenerator, journalLoaded, largeMessagesToDelete, mapPersistedAddressSettings, mapPersistedRoles, messageJournal, pageMaxConcurrentIO, perfBlastPages, started, storageManagerLock
Constructor and Description |
---|
JDBCJournalStorageManager(Configuration config,
ExecutorFactory executorFactory) |
JDBCJournalStorageManager(Configuration config,
ExecutorFactory executorFactory,
IOCriticalErrorListener criticalErrorListener) |
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) |
addBytesToLargeMessage, beforeStart, beforeStop, createFileForLargeMessage, createFileForLargeMessage, createLargeMessage, createLargeMessage, isReplicated, pageClosed, pageDeleted, pageWrite, parseLargeMessage, performCachedLargeMessageDeletes, startReplication, stop, stopReplication, storePendingLargeMessage
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, deleteSecurityRoles, generateID, getBindingsJournal, getContext, getCurrentID, getIDGenerator, getMessageJournal, getSingleThreadExecutor, isStarted, lineUpContext, loadBindingJournal, loadInternalOnly, loadMessageJournal, md5, newBindingEncoding, newContext, 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, storeReference, storeReferenceTransactional, storeSecurityRoles, updateDeliveryCount, updateDuplicateIDTransactional, updatePageTransaction, updatePageTransaction, updateScheduledDeliveryTime, updateScheduledDeliveryTimeTransactional, waitOnOperations, waitOnOperations
public JDBCJournalStorageManager(Configuration config, ExecutorFactory executorFactory)
public JDBCJournalStorageManager(Configuration config, ExecutorFactory executorFactory, IOCriticalErrorListener criticalErrorListener)
protected void init(Configuration config, IOCriticalErrorListener criticalErrorListener)
AbstractJournalStorageManager
init
in class JournalStorageManager
public void stop(boolean ioCriticalError) throws Exception
stop
in interface StorageManager
stop
in class JournalStorageManager
ioCriticalError
- is the server being stopped due to an IO critical errorException
public ByteBuffer allocateDirectBuffer(int size)
StorageManager
allocateDirectBuffer
in interface StorageManager
allocateDirectBuffer
in class JournalStorageManager
public void freeDirectBuffer(ByteBuffer buffer)
StorageManager
freeDirectBuffer
in interface StorageManager
freeDirectBuffer
in class JournalStorageManager
Copyright © 2016 The Apache Software Foundation. All rights reserved.