com.epam.fixengine.storage

Class MMFStorageFactory

java.lang.Object

com.epam.fixengine.storage.FilesystemStorageFactory

com.epam.fixengine.storage.MMFStorageFactory

All Implemented Interfaces:

StorageFactory

public class MMFStorageFactory
extends FilesystemStorageFactory

Provides ability to store messages in a file using the memory mapped files technology.

Field Summary

Fields inherited from class com.epam.fixengine.storage.FilesystemStorageFactory

backupIncomingLogFileLocator, backupOutgoingLogFileLocator, config, incomingLogFileLocator, outgoingLogFileLocator, propertyFileLocator, queueFileLocator, stateFileLocator

Constructor Summary

Constructors

Constructor and Description
MMFStorageFactory(com.epam.fixengine.configuration.Configuration configuration)

Method Summary

Modifier and Type	Method and Description
MessageStorage	getIncomingMessageStorage(SessionParameters sessionParameters) Gets incoming message storage.
MessageStorage	getOutgoingMessageStorage(SessionParameters sessionParameters) Gets outgoing message storage.
Queue<FIXFieldListWithType>	getQueue(SessionParameters sessionParameters) Gets queue for session.

Methods inherited from class com.epam.fixengine.storage.FilesystemStorageFactory

checkDirectories, createLocators, getBackupIncomingLogFileLocator, getBackupOutgoingLogFileLocator, getIncomingLogFileLocator, getOutgoingLogFileLocator, getPropertyFileLocator, getQueueFileLocator, getStateFileLocator, loadSessionParameters, saveSessionParameters, setBackupIncomingLogFileLocator, setBackupOutgoingLogFileLocator, setIncomingLogFileLocator, setOutgoingLogFileLocator, setPropertyFileLocator, setQueueFileLocator, setStateFileLocator

Methods inherited from class java.lang.Object

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

Constructor Detail

MMFStorageFactory

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

Method Detail

getIncomingMessageStorage

public MessageStorage getIncomingMessageStorage(SessionParameters sessionParameters)

Gets incoming message storage. If parameter incomingStorageIndexed configured, the message storage will be MMFIndexedMessageStorage, otherwise MMFMessageStorage

Specified by:

getIncomingMessageStorage in interface StorageFactory

Overrides:

getIncomingMessageStorage in class FilesystemStorageFactory

Parameters:

sessionParameters - the session parameters

Returns:

the incoming message storage

See Also:

StorageFactory

getOutgoingMessageStorage

public MessageStorage getOutgoingMessageStorage(SessionParameters sessionParameters)

Gets outgoing message storage. If parameter outgoingStorageIndexed configured, the message storage will be MMFIndexedMessageStorage, otherwise MMFMessageStorage

Specified by:

getOutgoingMessageStorage in interface StorageFactory

Overrides:

getOutgoingMessageStorage in class FilesystemStorageFactory

Parameters:

sessionParameters - the session parameters

Returns:

the outgoing message storage

getQueue

public Queue<FIXFieldListWithType> getQueue(SessionParameters sessionParameters)

Gets queue for session. If parameter inMemoryQueue configured, the queue will be InMemoryQueue, otherwise PersistentInMemoryQueue.

Specified by:

getQueue in interface StorageFactory

Overrides:

getQueue in class FilesystemStorageFactory

Parameters:

sessionParameters - the parameter for session

Returns:

the outgoing queue of messages