Package com.epam.fixengine.storage.file

Class ChronicleQueueStorage

java.lang.Object

com.epam.fixengine.storage.file.AbstractFileMessageStorage

com.epam.fixengine.storage.file.ChronicleQueueStorage

All Implemented Interfaces:

MessageStorage

public class ChronicleQueueStorage
extends AbstractFileMessageStorage
implements MessageStorage

Field Summary

Fields

Modifier and Type	Field	Description
static final int	WAITING_FILE_TO_REMOVE_IN_SEC

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

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

Constructor Summary

Constructors

Constructor	Description
ChronicleQueueStorage(com.epam.fixengine.configuration.Configuration configuration)

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
void	close()	Close the storage.
protected void	deleteFile(String fullPathToStorageFile)
protected long	getNextSequenceNumber()	Gets next sequence number.
protected void	openStorageFile()
void	retrieveMessages(long from, long to, MessageStorageListener listener, boolean blocking)	Retrieves message from storage.
static int	trimLength(net.openhft.chronicle.bytes.Bytes bytes)

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

appendMessage, appendMessage, appendMessageInternal, backupFile, backupStorage, backupStorageFile, 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

Methods inherited from interface com.epam.fixengine.storage.MessageStorage

appendMessage, appendMessage, backupStorage, initialize, retrieveMessage

Field Details

WAITING_FILE_TO_REMOVE_IN_SEC

public static final int WAITING_FILE_TO_REMOVE_IN_SEC

See Also:

• Constant Field Values

Constructor Details

ChronicleQueueStorage

public ChronicleQueueStorage(com.epam.fixengine.configuration.Configuration configuration)

Method Details

retrieveMessages

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

Description copied from interface: MessageStorage

Retrieves message from storage.

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 - - if error occurred.

See Also:

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

trimLength

public static int trimLength(net.openhft.chronicle.bytes.Bytes bytes)

openStorageFile

protected void openStorageFile()
                        throws IOException

Overrides:

openStorageFile in class AbstractFileMessageStorage

Throws:

IOException

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

deleteFile

protected void deleteFile(String fullPathToStorageFile)

Overrides:

deleteFile in class AbstractFileMessageStorage

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.

Specified by:

appendMessage in interface MessageStorage

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.

Specified by:

appendMessage in interface MessageStorage

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

Description copied from class: AbstractFileMessageStorage

Appends message to storage

Specified by:

appendMessageInternal in class AbstractFileMessageStorage

Parameters:

timestamp - the timestamp parameter

message - the array of bytes

Throws:

IOException - - if I/O error occurred

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