com.epam.fixengine.storage

Interface StorageFactory

All Known Implementing Classes:

ChronicleStorageFactory, FilesystemStorageFactory, InMemoryStorageFactory, MMFStorageFactory, SlicedFileStorageFactory

public interface StorageFactory

Base storage factory interface. Provides ability to create incoming and outgoing storage. To replace the standard implementation, use a storageFactory parameter in properties file.

Method Summary

Modifier and Type	Method and Description
MessageStorage	getIncomingMessageStorage(SessionParameters sessionParameters) Get incoming message storage instance.
MessageStorage	getOutgoingMessageStorage(SessionParameters sessionParameters) Get outgoing message storage instance.
Queue<FIXFieldListWithType>	getQueue(SessionParameters sessionParameters) Get outgoing message queue.
boolean	loadSessionParameters(SessionParameters sessionParameters, FIXSessionRuntimeState state) Save session parameters.
void	saveSessionParameters(SessionParameters sessionParameters, FIXSessionRuntimeState state) Save session parameters.

Method Detail

getIncomingMessageStorage

MessageStorage getIncomingMessageStorage(SessionParameters sessionParameters)

Get incoming message storage instance.

Parameters:

sessionParameters - session parameters

Returns:

the incoming message storage

getOutgoingMessageStorage

MessageStorage getOutgoingMessageStorage(SessionParameters sessionParameters)

Get outgoing message storage instance.

Parameters:

sessionParameters - session parameters

Returns:

the outgoing message storage

saveSessionParameters

void saveSessionParameters(SessionParameters sessionParameters,
                           FIXSessionRuntimeState state)
                    throws IOException

Save session parameters.

Parameters:

sessionParameters - session parameters

Throws:

IOException - - if error occurred

loadSessionParameters

boolean loadSessionParameters(SessionParameters sessionParameters,
                              FIXSessionRuntimeState state)

Save session parameters.

Parameters:

sessionParameters - session parameters

Returns:

true if parameters loaded

getQueue

Queue<FIXFieldListWithType> getQueue(SessionParameters sessionParameters)

Get outgoing message queue.

Parameters:

sessionParameters - session parameters

Returns:

the outgoing queue of messages