Package com.epam.fixengine.storage.file

Class FlatFileMessageStorage

java.lang.Object

com.epam.fixengine.storage.file.AbstractFileMessageStorage

com.epam.fixengine.storage.file.FlatFileMessageStorage

All Implemented Interfaces:

MessageStorage

Direct Known Subclasses:

IndexedMessageStorage, MMFMessageStorage, SlicedFileMessageStorage

public class FlatFileMessageStorage
extends AbstractFileMessageStorage

File message storage implementation.

Field Summary

Fields

Modifier and Type	Field	Description
protected ByteBuffer	buffer
protected long	channelLength
protected long	channelPosition
protected byte[]	dateFormattedBuffer
protected static final long	DELTA
protected int	maxBufferSize
protected int	maxStorageGrowSize
protected boolean	storageGrowSize
protected long	timestamp
protected boolean	timestampsInLogs
protected static final int	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
FlatFileMessageStorage()	Deprecated.
FlatFileMessageStorage(com.epam.fixengine.configuration.Configuration config)

Method Summary

Modifier and Type	Method	Description
void	appendMessage(byte[] timestampFormatted, byte[] message)	Appends message to storage with the given formatted timestampFormatted.
void	appendMessage(byte[] timestampFormatted, byte[] message, int offset, int length)	Appends message to storage with the given formatted timestamp.
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	getNextSequenceNumber()	Gets next sequence number.
boolean	isEnabledTimestamp()
protected void	openStorageFile()
void	retrieveMessages(long from, long to, MessageStorageListener listener, boolean blocking)	The method retrieveMessages is not supported in this instance.
static long	retrieveSequenceNumber(String fileName)	Retrieves the last sequence number.

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

appendMessage, appendMessage, appendMessageInternal, backupFile, backupStorage, backupStorageFile, close, deleteFile, deleteStorageFile, getFile, getFormatLength, 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

DELTA

protected static final long DELTA

See Also:

• Constant Field Values

WRITE_BUFFER_LENGTH_DEF

protected static final int WRITE_BUFFER_LENGTH_DEF

See Also:

• Constant Field Values

dateFormattedBuffer

protected byte[] dateFormattedBuffer

buffer

protected ByteBuffer buffer

maxBufferSize

protected int maxBufferSize

timestamp

protected long timestamp

timestampsInLogs

protected boolean timestampsInLogs

maxStorageGrowSize

protected int maxStorageGrowSize

storageGrowSize

protected boolean storageGrowSize

channelPosition

protected long channelPosition

channelLength

protected long channelLength

Constructor Details

FlatFileMessageStorage

@Deprecated
public FlatFileMessageStorage()

Deprecated.

Creates FlatFileMessageStorage.

FlatFileMessageStorage

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

Method Details

openStorageFile

protected void openStorageFile()
                        throws IOException

Overrides:

openStorageFile in class AbstractFileMessageStorage

Throws:

IOException

retrieveMessages

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

The method retrieveMessages is not supported in this instance.

Specified by:

retrieveMessages in interface MessageStorage

Specified by:

retrieveMessages in class AbstractFileMessageStorage

Parameters:

from - the from sequence number

to - the to sequence number

listener - the callback listener

blocking - if parameter is true, the execution start in current thread context, otherwise in the new thread context.

Throws:

IOException - - Message retrieval is not possible for flat files

See Also:

• AbstractFileMessageStorage.retrieveMessages(long, long, com.epam.fixengine.storage.MessageStorageListener, boolean)

getNextSequenceNumber

protected long getNextSequenceNumber()
                              throws IOException

Description copied from class: AbstractFileMessageStorage

Gets next sequence number.

Specified by:

getNextSequenceNumber in class AbstractFileMessageStorage

Throws:

IOException - - if I/O error occurred

appendMessage

public void appendMessage(byte[] timestampFormatted,
 byte[] message,
 int offset,
 int length)
                   throws IOException

Description copied from interface: MessageStorage

Appends message to storage with the given formatted timestamp.

Parameters:

timestampFormatted - the message timestamp

message - the message

offset - the initial offset

length - the length

Throws:

IOException - - if error occurred.

appendMessage

public void appendMessage(byte[] timestampFormatted,
 byte[] message)
                   throws IOException

Description copied from interface: MessageStorage

Appends message to storage with the given formatted timestampFormatted.

Parameters:

timestampFormatted - the message timestampFormatted

message - the message

Throws:

IOException - - if error occurred.

appendMessageInternal

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

Throws:

IOException

appendMessageInternal

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

Appends message to storage

Specified by:

appendMessageInternal in class AbstractFileMessageStorage

Parameters:

timestamp - the timestamp parameter

message - the array of bytes

offset -

length -

Throws:

IOException - - if I/O error occurred

isEnabledTimestamp

public boolean isEnabledTimestamp()

retrieveSequenceNumber

public static long retrieveSequenceNumber(String fileName)
                                   throws IOException

Retrieves the last sequence number.

Parameters:

fileName - the file name

Throws:

IOException - - if I/O error occurred