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

Constructor Summary

MMFStorageFactory(Configuration configuration)

Method Summary

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

getIncomingLogFileLocator, getOutgoingLogFileLocator, loadSessionParameters, saveSessionParameters, setIncomingLogFileLocator, setOutgoingLogFileLocator, setPropertyFileLocator, setQueueFileLocator

Methods inherited from class java.lang.Object

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

Constructor Detail

MMFStorageFactory

public MMFStorageFactory(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