org.hornetq.core.persistence.impl.journal

Class JournalStorageManager

java.lang.Object

org.hornetq.core.persistence.impl.journal.JournalStorageManager

All Implemented Interfaces:

StorageManager, HornetQComponent

public class JournalStorageManager
extends Object
implements StorageManager

A JournalStorageManager

Author:

Tim Fox, Clebert Suconic, Jeff Mesnil

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JournalStorageManager.AckDescribe
static class	JournalStorageManager.CursorAckRecordEncoding
static class	JournalStorageManager.DeleteEncoding
static class	JournalStorageManager.DeliveryCountUpdateEncoding
static class	JournalStorageManager.DuplicateIDEncoding
static class	JournalStorageManager.GroupingEncoding
static class	JournalStorageManager.HeuristicCompletionEncoding
static class	JournalStorageManager.LargeMessageEncoding
static class	JournalStorageManager.MessageDescribe
static class	JournalStorageManager.PageUpdateTXEncoding
static class	JournalStorageManager.PendingLargeMessageEncoding
static class	JournalStorageManager.PersistentQueueBindingEncoding
static class	JournalStorageManager.QueueEncoding
static class	JournalStorageManager.RefEncoding
static class	JournalStorageManager.ReferenceDescribe
static class	JournalStorageManager.ScheduledDeliveryEncoding
static class	JournalStorageManager.XidEncoding It's public as other classes may want to unparse data on tools

Field Summary

Fields

Modifier and Type	Field and Description
static byte	ACKNOWLEDGE_CURSOR
static byte	ACKNOWLEDGE_REF
static byte	ADD_LARGE_MESSAGE
static byte	ADD_LARGE_MESSAGE_PENDING
static byte	ADD_MESSAGE
static byte	ADD_REF
static byte	ADDRESS_SETTING_RECORD
static byte	DUPLICATE_ID
static byte	GROUP_RECORD
static byte	HEURISTIC_COMPLETION
static byte	ID_COUNTER_RECORD
static byte	PAGE_CURSOR_COUNTER_INC
static byte	PAGE_CURSOR_COUNTER_VALUE
static byte	PAGE_TRANSACTION
static byte	QUEUE_BINDING_RECORD
static byte	SECURITY_RECORD
static byte	SET_SCHEDULED_DELIVERY_TIME
static byte	UPDATE_DELIVERY_COUNT

Constructor Summary

Constructors

Constructor and Description
JournalStorageManager(Configuration config, ExecutorFactory executorFactory)
JournalStorageManager(Configuration config, ExecutorFactory executorFactory, IOCriticalErrorListener criticalErrorListener)
JournalStorageManager(Configuration config, ExecutorFactory executorFactory, ReplicationManager replicator, IOCriticalErrorListener criticalErrorListener)

Method Summary

Methods

Modifier and Type	Method and Description
void	addBytesToLargeMessage(SequentialFile file, long messageId, byte[] bytes)
void	addGrouping(GroupBinding groupBinding)
void	addQueueBinding(long tx, Binding binding)
void	afterCompleteOperations(IOAsyncTask run)
void	afterPageRead() We need a safeguard in place to avoid too much concurrent IO happening on Paging, otherwise the system may become irrensponsive if too many destinations are reading all the same time.
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	beforePageRead() We need a safeguard in place to avoid too much concurrent IO happening on Paging, otherwise the system may become irrensponsive if too many destinations are reading all the same time.
void	clearContext()
void	commit(long txID)
void	commit(long txID, boolean lineUpContext)
void	commitBindings(long txID)
void	confirmPendingLargeMessage(long recordID) We don't need messageID now but we are likely to need it we ever decide to support a database
void	confirmPendingLargeMessageTX(Transaction tx, long messageID, long recordID)
LargeServerMessage	createLargeMessage()
LargeServerMessage	createLargeMessage(long id, MessageInternal message)
void	deleteAddressSetting(SimpleString addressMatch)
void	deleteCursorAcknowledgeTransactional(long txID, long ackID)
void	deleteDuplicateID(long recordID)
void	deleteDuplicateIDTransactional(long txID, long recordID)
void	deleteGrouping(GroupBinding groupBinding)
void	deleteHeuristicCompletion(long id)
void	deleteIncrementRecord(long txID, long recordID)
void	deleteMessage(long messageID)
void	deletePageCounter(long txID, long recordID)
void	deletePageTransactional(long recordID)
void	deleteQueueBinding(long queueBindingID)
void	deleteSecurityRoles(SimpleString addressMatch)
static void	describeBindingJournal(String bindingsDir)
protected static void	describeJournal(SequentialFileFactory fileFactory, JournalImpl journal)
static void	describeMessagesJournal(String messagesDir)
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.
long	generateUniqueID()
Journal	getBindingsJournal()
OperationContext	getContext() Get the context associated with the thread for later reuse
protected OperationContext	getContext(boolean sync)
long	getCurrentUniqueID()
Journal	getMessageJournal()
Executor	getSingleThreadExecutor()
boolean	isReplicated()
boolean	isStarted()
void	lineUpContext()
JournalLoadInformation	loadBindingJournal(List<QueueBindingInfo> queueBindingInfos, List<GroupingInfo> groupingInfos)
JournalLoadInformation[]	loadInternalOnly() This method is only useful at the backup side.
JournalLoadInformation	loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long,Queue> queues, Map<Long,QueueBindingInfo> queueInfos, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, Set<Pair<Long,Long>> pendingLargeMessages)
protected static PersistedAddressSetting	newAddressEncoding(long id, HornetQBuffer buffer)
protected static JournalStorageManager.PersistentQueueBindingEncoding	newBindingEncoding(long id, HornetQBuffer buffer)
OperationContext	newContext(Executor executor) It just creates an OperationContext without associating it
protected static JournalStorageManager.GroupingEncoding	newGroupEncoding(long id, HornetQBuffer buffer)
static Object	newObjectEncoding(RecordInfo info)
static Object	newObjectEncoding(RecordInfo info, JournalStorageManager storageManager)
protected static PersistedRoles	newSecurityRecord(long id, HornetQBuffer buffer)
OperationContext	newSingleThreadContext()
void	pageClosed(SimpleString storeName, int pageNumber)
void	pageDeleted(SimpleString storeName, int pageNumber)
void	pageWrite(PagedMessage message, int pageNumber)
void	prepare(long txID, Xid xid)
List<PersistedAddressSetting>	recoverAddressSettings()
List<PersistedRoles>	recoverPersistedRoles()
void	rollback(long txID)
void	rollbackBindings(long txID)
void	setContext(OperationContext context) Set the context back to the thread
void	start()
void	stop()
void	stop(boolean ioCriticalError)
void	storeAcknowledge(long queueID, long messageID)
void	storeAcknowledgeTransactional(long txID, long queueID, long messageID)
void	storeAddressSetting(PersistedAddressSetting addressSetting)
void	storeCursorAcknowledge(long queueID, PagePosition position)
void	storeCursorAcknowledgeTransactional(long txID, long queueID, PagePosition position)
void	storeDuplicateID(SimpleString address, byte[] duplID, long recordID)
void	storeDuplicateIDTransactional(long txID, SimpleString address, byte[] duplID, long recordID)
long	storeHeuristicCompletion(Xid xid, boolean isCommit)
void	storeMessage(ServerMessage message)
void	storeMessageTransactional(long txID, ServerMessage message)
long	storePageCounter(long txID, long queueID, long value)
long	storePageCounterInc(long queueID, int value)
long	storePageCounterInc(long txID, long queueID, int value)
void	storePageTransaction(long txID, PageTransactionInfo pageTransaction)
long	storePendingLargeMessage(long messageID)
void	storeReference(long queueID, long messageID, boolean last)
void	storeReferenceTransactional(long txID, long queueID, long messageID)
void	storeSecurityRoles(PersistedRoles persistedRoles)
void	updateDeliveryCount(MessageReference ref)
void	updateDuplicateIDTransactional(long txID, SimpleString address, byte[] duplID, long recordID)
void	updatePageTransaction(long txID, PageTransactionInfo pageTransaction, int depages)
void	updatePageTransaction(PageTransactionInfo pageTransaction, int depages)
void	updateScheduledDeliveryTime(MessageReference ref)
void	updateScheduledDeliveryTimeTransactional(long txID, MessageReference ref)
void	waitOnOperations() Block until the operations are done.
boolean	waitOnOperations(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, wait

Field Detail

GROUP_RECORD

public static final byte GROUP_RECORD

See Also:

Constant Field Values

QUEUE_BINDING_RECORD

public static final byte QUEUE_BINDING_RECORD

See Also:

Constant Field Values

ID_COUNTER_RECORD

public static final byte ID_COUNTER_RECORD

See Also:

Constant Field Values

ADDRESS_SETTING_RECORD

public static final byte ADDRESS_SETTING_RECORD

See Also:

Constant Field Values

SECURITY_RECORD

public static final byte SECURITY_RECORD

See Also:

Constant Field Values

ADD_LARGE_MESSAGE_PENDING

public static final byte ADD_LARGE_MESSAGE_PENDING

See Also:

Constant Field Values

ADD_LARGE_MESSAGE

public static final byte ADD_LARGE_MESSAGE

See Also:

Constant Field Values

ADD_MESSAGE

public static final byte ADD_MESSAGE

See Also:

Constant Field Values

ADD_REF

public static final byte ADD_REF

See Also:

Constant Field Values

ACKNOWLEDGE_REF

public static final byte ACKNOWLEDGE_REF

See Also:

Constant Field Values

UPDATE_DELIVERY_COUNT

public static final byte UPDATE_DELIVERY_COUNT

See Also:

Constant Field Values

PAGE_TRANSACTION

public static final byte PAGE_TRANSACTION

See Also:

Constant Field Values

SET_SCHEDULED_DELIVERY_TIME

public static final byte SET_SCHEDULED_DELIVERY_TIME

See Also:

Constant Field Values

DUPLICATE_ID

public static final byte DUPLICATE_ID

See Also:

Constant Field Values

HEURISTIC_COMPLETION

public static final byte HEURISTIC_COMPLETION

See Also:

Constant Field Values

ACKNOWLEDGE_CURSOR

public static final byte ACKNOWLEDGE_CURSOR

See Also:

Constant Field Values

PAGE_CURSOR_COUNTER_VALUE

public static final byte PAGE_CURSOR_COUNTER_VALUE

See Also:

Constant Field Values

PAGE_CURSOR_COUNTER_INC

public static final byte PAGE_CURSOR_COUNTER_INC

See Also:

Constant Field Values

Constructor Detail

JournalStorageManager

public JournalStorageManager(Configuration config,
                     ExecutorFactory executorFactory)

JournalStorageManager

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

JournalStorageManager

public JournalStorageManager(Configuration config,
                     ExecutorFactory executorFactory,
                     ReplicationManager replicator,
                     IOCriticalErrorListener criticalErrorListener)

Method Detail

clearContext

public void clearContext()

Specified by:

clearContext in interface StorageManager

isReplicated

public boolean isReplicated()

Specified by:

isReplicated in interface StorageManager

waitOnOperations

public void waitOnOperations()
                      throws Exception

Description copied from interface: StorageManager

Block 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:

waitOnOperations in interface StorageManager

Throws:

Exception

waitOnOperations

public boolean waitOnOperations(long timeout)
                         throws Exception

Description copied from interface: StorageManager

Block 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:

waitOnOperations in interface StorageManager

Throws:

Exception

pageClosed

public void pageClosed(SimpleString storeName,
              int pageNumber)

Specified by:

pageClosed in interface StorageManager

pageDeleted

public void pageDeleted(SimpleString storeName,
               int pageNumber)

Specified by:

pageDeleted in interface StorageManager

pageWrite

public void pageWrite(PagedMessage message,
             int pageNumber)

Specified by:

pageWrite in interface StorageManager

getContext

public OperationContext getContext()

Description copied from interface: StorageManager

Get the context associated with the thread for later reuse

Specified by:

getContext in interface StorageManager

setContext

public void setContext(OperationContext context)

Description copied from interface: StorageManager

Set the context back to the thread

Specified by:

setContext in interface StorageManager

getSingleThreadExecutor

public Executor getSingleThreadExecutor()

newSingleThreadContext

public OperationContext newSingleThreadContext()

Specified by:

newSingleThreadContext in interface StorageManager

newContext

public OperationContext newContext(Executor executor)

Description copied from interface: StorageManager

It just creates an OperationContext without associating it

Specified by:

newContext in interface StorageManager

afterCompleteOperations

public void afterCompleteOperations(IOAsyncTask run)

Specified by:

afterCompleteOperations in interface StorageManager

generateUniqueID

public long generateUniqueID()

Specified by:

generateUniqueID in interface StorageManager

getCurrentUniqueID

public long getCurrentUniqueID()

Specified by:

getCurrentUniqueID in interface StorageManager

createLargeMessage

public LargeServerMessage createLargeMessage()

Specified by:

createLargeMessage in interface StorageManager

addBytesToLargeMessage

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

Throws:

Exception

createLargeMessage

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

Specified by:

createLargeMessage in interface StorageManager

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:

Throws:

Exception

storePendingLargeMessage

public long storePendingLargeMessage(long messageID)
                              throws Exception

Throws:

Exception

confirmPendingLargeMessageTX

public void confirmPendingLargeMessageTX(Transaction tx,
                                long messageID,
                                long recordID)
                                  throws Exception

Specified by:

confirmPendingLargeMessageTX in interface StorageManager

Throws:

Exception

confirmPendingLargeMessage

public void confirmPendingLargeMessage(long recordID)
                                throws Exception

We don't need messageID now but we are likely to need it we ever decide to support a database

Specified by:

confirmPendingLargeMessage in interface StorageManager

Throws:

Exception

storeMessage

public void storeMessage(ServerMessage message)
                  throws Exception

Specified by:

storeMessage in interface StorageManager

Throws:

Exception

storeReference

public void storeReference(long queueID,
                  long messageID,
                  boolean last)
                    throws Exception

Specified by:

storeReference in interface StorageManager

Throws:

Exception

storeAcknowledge

public void storeAcknowledge(long queueID,
                    long messageID)
                      throws Exception

Specified by:

storeAcknowledge in interface StorageManager

Throws:

Exception

storeCursorAcknowledge

public void storeCursorAcknowledge(long queueID,
                          PagePosition position)
                            throws Exception

Specified by:

storeCursorAcknowledge in interface StorageManager

Throws:

Exception

deleteMessage

public void deleteMessage(long messageID)
                   throws Exception

Specified by:

deleteMessage in interface StorageManager

Throws:

Exception

updateScheduledDeliveryTime

public void updateScheduledDeliveryTime(MessageReference ref)
                                 throws Exception

Specified by:

updateScheduledDeliveryTime in interface StorageManager

Throws:

Exception

storeDuplicateID

public void storeDuplicateID(SimpleString address,
                    byte[] duplID,
                    long recordID)
                      throws Exception

Specified by:

storeDuplicateID in interface StorageManager

Throws:

Exception

deleteDuplicateID

public void deleteDuplicateID(long recordID)
                       throws Exception

Specified by:

deleteDuplicateID in interface StorageManager

Throws:

Exception

storeMessageTransactional

public void storeMessageTransactional(long txID,
                             ServerMessage message)
                               throws Exception

Specified by:

storeMessageTransactional in interface StorageManager

Throws:

Exception

storePageTransaction

public void storePageTransaction(long txID,
                        PageTransactionInfo pageTransaction)
                          throws Exception

Specified by:

storePageTransaction in interface StorageManager

Throws:

Exception

updatePageTransaction

public void updatePageTransaction(long txID,
                         PageTransactionInfo pageTransaction,
                         int depages)
                           throws Exception

Specified by:

updatePageTransaction in interface StorageManager

Throws:

Exception

updatePageTransaction

public void updatePageTransaction(PageTransactionInfo pageTransaction,
                         int depages)
                           throws Exception

Specified by:

updatePageTransaction in interface StorageManager

Throws:

Exception

storeReferenceTransactional

public void storeReferenceTransactional(long txID,
                               long queueID,
                               long messageID)
                                 throws Exception

Specified by:

storeReferenceTransactional in interface StorageManager

Throws:

Exception

storeAcknowledgeTransactional

public void storeAcknowledgeTransactional(long txID,
                                 long queueID,
                                 long messageID)
                                   throws Exception

Specified by:

storeAcknowledgeTransactional in interface StorageManager

Throws:

Exception

storeCursorAcknowledgeTransactional

public void storeCursorAcknowledgeTransactional(long txID,
                                       long queueID,
                                       PagePosition position)
                                         throws Exception

Specified by:

storeCursorAcknowledgeTransactional in interface StorageManager

Throws:

Exception

deleteCursorAcknowledgeTransactional

public void deleteCursorAcknowledgeTransactional(long txID,
                                        long ackID)
                                          throws Exception

Specified by:

deleteCursorAcknowledgeTransactional in interface StorageManager

Throws:

Exception

storeHeuristicCompletion

public long storeHeuristicCompletion(Xid xid,
                            boolean isCommit)
                              throws Exception

Specified by:

storeHeuristicCompletion in interface StorageManager

Throws:

Exception

deleteHeuristicCompletion

public void deleteHeuristicCompletion(long id)
                               throws Exception

Specified by:

deleteHeuristicCompletion in interface StorageManager

Throws:

Exception

deletePageTransactional

public void deletePageTransactional(long recordID)
                             throws Exception

Specified by:

deletePageTransactional in interface StorageManager

Throws:

Exception

updateScheduledDeliveryTimeTransactional

public void updateScheduledDeliveryTimeTransactional(long txID,
                                            MessageReference ref)
                                              throws Exception

Specified by:

updateScheduledDeliveryTimeTransactional in interface StorageManager

Throws:

Exception

prepare

public void prepare(long txID,
           Xid xid)
             throws Exception

Specified by:

prepare in interface StorageManager

Throws:

Exception

commit

public void commit(long txID)
            throws Exception

Specified by:

commit in interface StorageManager

Throws:

Exception

commitBindings

public void commitBindings(long txID)
                    throws Exception

Specified by:

commitBindings in interface StorageManager

Throws:

Exception

rollbackBindings

public void rollbackBindings(long txID)
                      throws Exception

Specified by:

rollbackBindings in interface StorageManager

Throws:

Exception

commit

public void commit(long txID,
          boolean lineUpContext)
            throws Exception

Specified by:

commit in interface StorageManager

Throws:

Exception

rollback

public void rollback(long txID)
              throws Exception

Specified by:

rollback in interface StorageManager

Throws:

Exception

storeDuplicateIDTransactional

public void storeDuplicateIDTransactional(long txID,
                                 SimpleString address,
                                 byte[] duplID,
                                 long recordID)
                                   throws Exception

Specified by:

storeDuplicateIDTransactional in interface StorageManager

Throws:

Exception

updateDuplicateIDTransactional

public void updateDuplicateIDTransactional(long txID,
                                  SimpleString address,
                                  byte[] duplID,
                                  long recordID)
                                    throws Exception

Specified by:

updateDuplicateIDTransactional in interface StorageManager

Throws:

Exception

deleteDuplicateIDTransactional

public void deleteDuplicateIDTransactional(long txID,
                                  long recordID)
                                    throws Exception

Specified by:

deleteDuplicateIDTransactional in interface StorageManager

Throws:

Exception

updateDeliveryCount

public void updateDeliveryCount(MessageReference ref)
                         throws Exception

Specified by:

updateDeliveryCount in interface StorageManager

Throws:

Exception

storeAddressSetting

public void storeAddressSetting(PersistedAddressSetting addressSetting)
                         throws Exception

Specified by:

storeAddressSetting in interface StorageManager

Throws:

Exception

recoverAddressSettings

public List<PersistedAddressSetting> recoverAddressSettings()
                                                     throws Exception

Specified by:

recoverAddressSettings in interface StorageManager

Throws:

Exception

recoverPersistedRoles

public List<PersistedRoles> recoverPersistedRoles()
                                           throws Exception

Specified by:

recoverPersistedRoles in interface StorageManager

Throws:

Exception

storeSecurityRoles

public void storeSecurityRoles(PersistedRoles persistedRoles)
                        throws Exception

Specified by:

storeSecurityRoles in interface StorageManager

Throws:

Exception

deleteAddressSetting

public void deleteAddressSetting(SimpleString addressMatch)
                          throws Exception

Specified by:

deleteAddressSetting in interface StorageManager

Throws:

Exception

deleteSecurityRoles

public void deleteSecurityRoles(SimpleString addressMatch)
                         throws Exception

Specified by:

deleteSecurityRoles in interface StorageManager

Throws:

Exception

loadMessageJournal

public JournalLoadInformation loadMessageJournal(PostOffice postOffice,
                                        PagingManager pagingManager,
                                        ResourceManager resourceManager,
                                        Map<Long,Queue> queues,
                                        Map<Long,QueueBindingInfo> queueInfos,
                                        Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
                                        Set<Pair<Long,Long>> pendingLargeMessages)
                                          throws Exception

Specified by:

loadMessageJournal in interface StorageManager

Throws:

Exception

addGrouping

public void addGrouping(GroupBinding groupBinding)
                 throws Exception

Specified by:

addGrouping in interface StorageManager

Throws:

Exception

deleteGrouping

public void deleteGrouping(GroupBinding groupBinding)
                    throws Exception

Specified by:

deleteGrouping in interface StorageManager

Throws:

Exception

addQueueBinding

public void addQueueBinding(long tx,
                   Binding binding)
                     throws Exception

Specified by:

addQueueBinding in interface StorageManager

Throws:

Exception

deleteQueueBinding

public void deleteQueueBinding(long queueBindingID)
                        throws Exception

Specified by:

deleteQueueBinding in interface StorageManager

Throws:

Exception

storePageCounterInc

public long storePageCounterInc(long txID,
                       long queueID,
                       int value)
                         throws Exception

Specified by:

storePageCounterInc in interface StorageManager

Returns:

the ID with the increment record

Throws:

Exception

storePageCounterInc

public long storePageCounterInc(long queueID,
                       int value)
                         throws Exception

Specified by:

storePageCounterInc in interface StorageManager

Returns:

the ID with the increment record

Throws:

Exception

storePageCounter

public long storePageCounter(long txID,
                    long queueID,
                    long value)
                      throws Exception

Specified by:

storePageCounter in interface StorageManager

Returns:

The ID with the stored counter

Throws:

Exception

deleteIncrementRecord

public void deleteIncrementRecord(long txID,
                         long recordID)
                           throws Exception

Specified by:

deleteIncrementRecord in interface StorageManager

Throws:

Exception

deletePageCounter

public void deletePageCounter(long txID,
                     long recordID)
                       throws Exception

Specified by:

deletePageCounter in interface StorageManager

Throws:

Exception

describeBindingJournal

public static void describeBindingJournal(String bindingsDir)
                                   throws Exception

Throws:

Exception

describeMessagesJournal

public static void describeMessagesJournal(String messagesDir)
                                    throws Exception

Throws:

Exception

loadBindingJournal

public JournalLoadInformation loadBindingJournal(List<QueueBindingInfo> queueBindingInfos,
                                        List<GroupingInfo> groupingInfos)
                                          throws Exception

Specified by:

loadBindingJournal in interface StorageManager

Throws:

Exception

lineUpContext

public void lineUpContext()

Specified by:

lineUpContext in interface StorageManager

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

stop

public void stop(boolean ioCriticalError)
          throws Exception

Specified by:

stop in interface StorageManager

Parameters:

ioCriticalError - is the server being stopped due to an IO critical error

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

loadInternalOnly

public JournalLoadInformation[] loadInternalOnly()
                                          throws Exception

Description copied from interface: StorageManager

This method is only useful at the backup side. We only load internal structures making the journals ready for append mode on the backup side.

Specified by:

loadInternalOnly in interface StorageManager

Throws:

Exception

beforePageRead

public void beforePageRead()
                    throws Exception

Description copied from interface: StorageManager

We need a safeguard in place to avoid too much concurrent IO happening on Paging, otherwise the system may become irrensponsive if too many destinations are reading all the same time. This is called before we read, so we can limit concurrent reads

Specified by:

beforePageRead in interface StorageManager

Throws:

Exception

afterPageRead

public void afterPageRead()
                   throws Exception

Description copied from interface: StorageManager

We need a safeguard in place to avoid too much concurrent IO happening on Paging, otherwise the system may become irrensponsive if too many destinations are reading all the same time. This is called after we read, so we can limit concurrent reads

Specified by:

afterPageRead in interface StorageManager

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

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

getMessageJournal

public Journal getMessageJournal()

getBindingsJournal

public Journal getBindingsJournal()

getContext

protected OperationContext getContext(boolean sync)

newObjectEncoding

public static Object newObjectEncoding(RecordInfo info)

newObjectEncoding

public static Object newObjectEncoding(RecordInfo info,
                       JournalStorageManager storageManager)

newSecurityRecord

protected static PersistedRoles newSecurityRecord(long id,
                               HornetQBuffer buffer)

Parameters:

id -

buffer -

Returns:

newAddressEncoding

protected static PersistedAddressSetting newAddressEncoding(long id,
                                         HornetQBuffer buffer)

Parameters:

id -

buffer -

Returns:

newGroupEncoding

protected static JournalStorageManager.GroupingEncoding newGroupEncoding(long id,
                                                      HornetQBuffer buffer)

Parameters:

id -

buffer -

Returns:

newBindingEncoding

protected static JournalStorageManager.PersistentQueueBindingEncoding newBindingEncoding(long id,
                                                                      HornetQBuffer buffer)

Parameters:

id -

buffer -

Returns:

describeJournal

protected static void describeJournal(SequentialFileFactory fileFactory,
                   JournalImpl journal)
                               throws Exception

Parameters:

fileFactory -

journal -

Throws:

Exception