Package com.epam.fixengine.storage.file

Class IndexedMessageStorage

java.lang.Object

com.epam.fixengine.storage.file.AbstractFileMessageStorage

com.epam.fixengine.storage.file.FlatFileMessageStorage

com.epam.fixengine.storage.file.IndexedMessageStorage

All Implemented Interfaces:

MessageStorage

public class IndexedMessageStorage
extends FlatFileMessageStorage

Indexed message storage implementation.

See Also:

• FilesystemStorageFactory

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_EXT

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	Description
IndexedMessageStorage(com.epam.fixengine.configuration.Configuration config)

Method Summary

Modifier and Type	Method	Description
protected void	appendMessageIndexToFile(byte[] message, int offset, int length, long msgPos, long savedRecordLen)
long	appendMessageInternal(byte[] timestampFormatted, byte[] message, int offset, int length)
long	appendMessageInternal(long timestamp, byte[] message, int offset, int length)	Appends message to storage
protected long	appendMessageToFile(long timestamp, byte[] message, int offset, int length)
protected void	backupStorageFile(String fullPathToStorageFile, String fullPathToDestinationBackupFile)	Backups storage file.
void	close()	Close the storage.
protected void	deleteStorageFile(String fullPathToStorageFile)	Deletes storage file.
protected int	getFormatLength()
protected void	openStorageFile()	Opens the indexed file.
protected byte[]	readFromStorage(FileChannel readChannel, long readFrom, int msgLen)
void	retrieveMessages(long from, long to, MessageStorageListener listener, boolean blocking)	Retrieves message from storage.
void	setIndexFileExtension(String indexFileExtension)	Deprecated.
protected void	setPrefixFormat(String prefixFormat)	Deprecated.

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

appendMessage, appendMessage, getNextSequenceNumber, isEnabledTimestamp, retrieveSequenceNumber

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

appendMessage, appendMessage, appendMessageInternal, backupFile, backupStorage, deleteFile, getFile, getPrefixFormat, initialize, 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

Field Details

DEFAULT_EXT

public static final String DEFAULT_EXT

See Also:

• Constant Field Values

Constructor Details

IndexedMessageStorage

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

Method Details

setIndexFileExtension

@Deprecated
public void setIndexFileExtension(String indexFileExtension)

Deprecated.

setPrefixFormat

@Deprecated
protected void setPrefixFormat(String prefixFormat)

Deprecated.

getFormatLength

protected int getFormatLength()

Overrides:

getFormatLength in class AbstractFileMessageStorage

retrieveMessages

public void retrieveMessages(long from,
 long to,
 MessageStorageListener listener,
 boolean blocking)
                      throws IOException

Retrieves message from storage.

Specified by:

retrieveMessages in interface MessageStorage

Overrides:

retrieveMessages in class FlatFileMessageStorage

Parameters:

from - the start sequence position

to - the end sequence position

listener - the callback listener

blocking - if sets to true the method call not blocking

Throws:

IOException - - Message retrieval is not possible for flat files

See Also:

• FlatFileMessageStorage

readFromStorage

protected byte[] readFromStorage(FileChannel readChannel,
 long readFrom,
 int msgLen)
                          throws IOException

Throws:

IOException

openStorageFile

protected void openStorageFile()
                        throws IOException

Opens the indexed file.

Overrides:

openStorageFile in class FlatFileMessageStorage

Throws:

IOException - - if I/O errors occurred

close

public void close()
           throws IOException

Close the storage.

Specified by:

close in interface MessageStorage

Overrides:

close in class AbstractFileMessageStorage

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

appendMessageInternal

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

Description copied from class: FlatFileMessageStorage

Appends message to storage

Overrides:

appendMessageInternal in class FlatFileMessageStorage

Parameters:

timestamp - the timestamp parameter

message - the array of bytes

Throws:

IOException - - if I/O error occurred

See Also:

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

appendMessageIndexToFile

protected void appendMessageIndexToFile(byte[] message,
 int offset,
 int length,
 long msgPos,
 long savedRecordLen)
                                 throws IOException

Throws:

IOException

appendMessageToFile

protected long appendMessageToFile(long timestamp,
 byte[] message,
 int offset,
 int length)
                            throws IOException

Throws:

IOException

backupStorageFile

protected void backupStorageFile(String fullPathToStorageFile,
 String fullPathToDestinationBackupFile)
                          throws IOException

Description copied from class: AbstractFileMessageStorage

Backups storage file.

Overrides:

backupStorageFile in class AbstractFileMessageStorage

Parameters:

fullPathToStorageFile - the path to file of in/out file

fullPathToDestinationBackupFile - the destination place to backup file

Throws:

IOException

deleteStorageFile

protected void deleteStorageFile(String fullPathToStorageFile)

Description copied from class: AbstractFileMessageStorage

Deletes storage file.

Overrides:

deleteStorageFile in class AbstractFileMessageStorage

Parameters:

fullPathToStorageFile - the path to in/out file