Package com.epam.fixengine.storage.file

Class SlicedFileMessageStorage

java.lang.Object

com.epam.fixengine.storage.file.AbstractFileMessageStorage

com.epam.fixengine.storage.file.FlatFileMessageStorage

com.epam.fixengine.storage.file.SlicedFileMessageStorage

All Implemented Interfaces:

MessageStorage

Direct Known Subclasses:

SlicedIndexedMessageStorage

public class SlicedFileMessageStorage
extends FlatFileMessageStorage

Field Summary

Fields

Modifier and Type	Field	Description
protected com.epam.fixengine.storage.file.SlicedFileManager	fileManager
protected long	maxFileSize	The default maximum file size is 100MB.

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

Method Summary

Modifier and Type	Method	Description
long	appendMessageInternal(long timestamp, byte[] message, int offset, int length)	Appends message to storage
protected void	backupStorageFile(String fullPathToStorageFile, String fullPathToDestinationBackupFile)	Backups storage file.
protected void	deleteStorageFile(String fullPathToStorageFile)	Deletes storage file.
long	getMaxFileSize()
long	initialize()	Initialize the storage.
protected void	nextChunk()
void	setFile(String file)	Sets the file.
void	setMaxFileSize(long maxFileSize)

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, close, deleteFile, getFile, getFormatLength, getPrefixFormat, initialized, isClosed, openStorage, retrieveMessage, setBackupFileLocator, setFileLocator

Methods inherited from class java.lang.Object

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

Field Details

maxFileSize

protected long maxFileSize

The default maximum file size is 100MB.

fileManager

protected com.epam.fixengine.storage.file.SlicedFileManager fileManager

Constructor Details

SlicedFileMessageStorage

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

Method Details

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

setFile

public void setFile(String file)

Description copied from class: AbstractFileMessageStorage

Sets the file.

Overrides:

setFile in class AbstractFileMessageStorage

Parameters:

file - the file

getMaxFileSize

public long getMaxFileSize()

setMaxFileSize

public void setMaxFileSize(long maxFileSize)

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

nextChunk

protected void nextChunk()
                  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