com.epam.fixengine.storage.file

Class MMFMessageStorage

java.lang.Object

com.epam.fixengine.storage.file.AbstractFileMessageStorage

com.epam.fixengine.storage.file.FlatFileMessageStorage

com.epam.fixengine.storage.file.MMFMessageStorage

All Implemented Interfaces:

MessageStorage

public class MMFMessageStorage
extends FlatFileMessageStorage

WARNING: This implementation used class which is Sun proprietary API(HotSpot VM). User: Mykhailo_Sereda Date: 07.05.12 Time: 18:34

Field Summary

Fields inherited from class com.epam.fixengine.storage.file.FlatFileMessageStorage

buffer, channelLength, channelPosition, dateFormattedBuffer, DELTA, maxBufferSize, maxStorageGrowSize, storageGrowSize, timestamp, timestampsInLogs, WRITE_BUFFER_LENGTH_DEF

Fields inherited from class com.epam.fixengine.storage.file.AbstractFileMessageStorage

accessFile, channel, configuration, isForcedFlush, maskedTags, NEW_LINE, storageTimestamp

Constructor Summary

Constructors

Constructor and Description
MMFMessageStorage(com.epam.fixengine.configuration.Configuration config)

Method Summary

Modifier and Type	Method and Description
long	appendMessageInternal(byte[] timestampFormatted, byte[] message, int offset, int length)
void	close() Close the storage.
long	initialize() Initialize the storage.

Methods inherited from class com.epam.fixengine.storage.file.FlatFileMessageStorage

appendMessage, appendMessage, appendMessageInternal, getNextSequenceNumber, isEnabledTimestamp, openStorageFile, retrieveMessages, retrieveSequenceNumber

Methods inherited from class com.epam.fixengine.storage.file.AbstractFileMessageStorage

appendMessage, appendMessage, appendMessageInternal, backupFile, backupStorage, backupStorageFile, deleteFile, deleteStorageFile, getFile, getFormatLength, getPrefixFormat, initialized, isClosed, openStorage, retrieveMessage, setBackupFileLocator, setFile, setFileLocator

Methods inherited from class java.lang.Object

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

Constructor Detail

MMFMessageStorage

public MMFMessageStorage(com.epam.fixengine.configuration.Configuration config)

Method Detail

initialize

public long initialize()
                throws IOException

Description copied from class: AbstractFileMessageStorage

Initialize the storage.

Specified by:

initialize in interface MessageStorage

Overrides:

initialize in class AbstractFileMessageStorage

Returns:

the last sequence number

Throws:

IOException - - if I/O error occurred

appendMessageInternal

public long appendMessageInternal(byte[] timestampFormatted,
                                  byte[] message,
                                  int offset,
                                  int length)
                           throws IOException

Overrides:

appendMessageInternal in class FlatFileMessageStorage

Throws:

IOException

See Also:

AbstractFileMessageStorage.appendMessageInternal(long, byte[], int, int)

close

public void close()
           throws IOException

Description copied from class: AbstractFileMessageStorage

Close the storage.

Specified by:

close in interface MessageStorage

Overrides:

close in class AbstractFileMessageStorage

Throws:

IOException - - if I/O error occurred