Class MmfStorageFactory
Provides ability to store messages in a file using the memory mapped files technology.
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 MmfStorageFactory : FilesystemStorageFactory, IStorageFactory
Constructors
MmfStorageFactory(Config)
Declaration
public MmfStorageFactory(Config configuration)
Parameters
Type | Name | Description |
---|---|---|
Config | configuration |
Methods
GetIncomingMessageStorage(SessionParameters)
Gets incoming message storage.
If parameter incomingStorageIndexed
configured, the message storage will be MmfIndexedMessageStorage,
otherwise MmfMessageStorage
Declaration
public override IMessageStorage GetIncomingMessageStorage(SessionParameters sessionParameters)
Parameters
Type | Name | Description |
---|---|---|
SessionParameters | sessionParameters | the session parameters |
Returns
Type | Description |
---|---|
IMessageStorage |
Overrides
See Also
GetOutgoingMessageStorage(SessionParameters)
Gets outgoing message storage.
If parameter outgoingStorageIndexed
configured, the message storage will be MmfIndexedMessageStorage,
otherwise MmfMessageStorage
Declaration
public override IMessageStorage GetOutgoingMessageStorage(SessionParameters sessionParameters)
Parameters
Type | Name | Description |
---|---|---|
SessionParameters | sessionParameters | the session parameters |
Returns
Type | Description |
---|---|
IMessageStorage |
Overrides
GetQueue(SessionParameters)
Gets queue for session.
If parameter inMemoryQueue
configured, the queue will be InMemoryQueue<T>,
otherwise PersistentInMemoryQueue<T>
Declaration
public override IQueue<FixMessageWithType> GetQueue(SessionParameters sessionParameters)
Parameters
Type | Name | Description |
---|---|---|
SessionParameters | sessionParameters | the parameter for session |
Returns
Type | Description |
---|---|
IQueue<FixMessageWithType> |