Class FilesystemStorageFactory

Provides ability to store messages in the file.

Inheritance
System.Object
FilesystemStorageFactory
MmfStorageFactory
SlicedFileStorageFactory
Implements
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: FixAntenna.FixEngine.Storage
Assembly: FixAntenna.Core.dll
Syntax
public class FilesystemStorageFactory : IStorageFactory

Constructors

FilesystemStorageFactory(Config)

Creates the FilesystemStorageFactory storage.

Declaration
public FilesystemStorageFactory(Config configuration)
Parameters
Type Name Description
Config configuration

Fields

BackupIncomingLogFileLocator

Locator for backup files of incoming storage

Declaration
protected ILogFileLocator BackupIncomingLogFileLocator
Field Value
Type Description
ILogFileLocator

BackupOutgoingLogFileLocator

Locator for backup files of outgoing storage

Declaration
protected ILogFileLocator BackupOutgoingLogFileLocator
Field Value
Type Description
ILogFileLocator

Config

Declaration
protected ConfigurationAdaptor Config
Field Value
Type Description
ConfigurationAdaptor

IncomingLogFileLocator

Locator for incoming storage file

Declaration
protected ILogFileLocator IncomingLogFileLocator
Field Value
Type Description
ILogFileLocator

OutgoingLogFileLocator

Locator for outgoing storage file

Declaration
protected ILogFileLocator OutgoingLogFileLocator
Field Value
Type Description
ILogFileLocator

PropertyFileLocator

Locator for session property file

Declaration
protected ILogFileLocator PropertyFileLocator
Field Value
Type Description
ILogFileLocator

QueueFileLocator

Locator for outgoing queue

Declaration
protected ILogFileLocator QueueFileLocator
Field Value
Type Description
ILogFileLocator

StateFileLocator

Declaration
protected ILogFileLocator StateFileLocator
Field Value
Type Description
ILogFileLocator

Methods

GetIncomingLogFileLocator()

Declaration
public virtual ILogFileLocator GetIncomingLogFileLocator()
Returns
Type Description
ILogFileLocator

GetIncomingMessageStorage(SessionParameters)

Gets incoming message storage. If parameter incomingStorageIndexed configured, the message storage will be IndexedMessageStorage, otherwise FlatFileMessageStorage

Declaration
public virtual IMessageStorage GetIncomingMessageStorage(SessionParameters sessionParameters)
Parameters
Type Name Description
SessionParameters sessionParameters

the session parameters
Returns
Type Description
IMessageStorage
See Also

GetOutgoingLogFileLocator()

Declaration
public virtual ILogFileLocator GetOutgoingLogFileLocator()
Returns
Type Description
ILogFileLocator

GetOutgoingMessageStorage(SessionParameters)

Gets outgoing message storage. If parameter outgoingStorageIndexed configured, the message storage will be IndexedMessageStorage, otherwise FlatFileMessageStorage

Declaration
public virtual IMessageStorage GetOutgoingMessageStorage(SessionParameters sessionParameters)
Parameters
Type Name Description
SessionParameters sessionParameters

the session parameters
Returns
Type Description
IMessageStorage

GetQueue(SessionParameters)

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

Declaration
public virtual IQueue<FixMessageWithType> GetQueue(SessionParameters sessionParameters)
Parameters
Type Name Description
SessionParameters sessionParameters

the parameter for session
Returns
Type Description
IQueue<FixMessageWithType>

LoadSessionParameters(SessionParameters, FixSessionRuntimeState)

Loads session parameters from file.

Declaration
public virtual bool LoadSessionParameters(SessionParameters sessionParameters, FixSessionRuntimeState state)
Parameters
Type Name Description
SessionParameters sessionParameters

the session parameters
FixSessionRuntimeState state
Returns
Type Description
System.Boolean

true if loaded

SaveSessionParameters(SessionParameters, FixSessionRuntimeState)

Stores session parameters to file.

Declaration
public virtual void SaveSessionParameters(SessionParameters sessionParameters, FixSessionRuntimeState state)
Parameters
Type Name Description
SessionParameters sessionParameters

the session parameters
FixSessionRuntimeState state
Exceptions
Type Condition
System.IO.IOException

if I/O error occurred

SetIncomingLogFileLocator(ILogFileLocator)

Declaration
public virtual void SetIncomingLogFileLocator(ILogFileLocator incomingLogFileLocator)
Parameters
Type Name Description
ILogFileLocator incomingLogFileLocator

SetOutgoingLogFileLocator(ILogFileLocator)

Declaration
public virtual void SetOutgoingLogFileLocator(ILogFileLocator outgoingLogFileLocator)
Parameters
Type Name Description
ILogFileLocator outgoingLogFileLocator

SetPropertyFileLocator(ILogFileLocator)

Declaration
public virtual void SetPropertyFileLocator(ILogFileLocator propertyFileLocator)
Parameters
Type Name Description
ILogFileLocator propertyFileLocator

SetQueueFileLocator(ILogFileLocator)

Declaration
public virtual void SetQueueFileLocator(ILogFileLocator queueFileLocator)
Parameters
Type Name Description
ILogFileLocator queueFileLocator

Implements