Interface ISessionStorage

Session's pluggable storage.

Inherited Members

Namespace: OnixS.Fix.Storage

Assembly: OnixS.Fix.Engine.dll

Syntax

public interface ISessionStorage : IDisposable

Properties

Id

Storage unique id.

Declaration

string Id { get; }

Property Value

Type	Description
String	Unique id

InSeqNum

Last inbound message sequence number or 0 if no incoming message is stored.

Declaration

int InSeqNum { get; set; }

Property Value

Type	Description
Int32	Inbound sequence number

MaxStorageSize

The maximum size of the storage.

Declaration

long MaxStorageSize { get; set; }

Property Value

Type	Description
Int64	Maximum size of the storage

MessageMode

Identifies the type of message objects that should be created.

Declaration

MessageMode MessageMode { get; set; }

Property Value

Type	Description
MessageMode

OutSeqNum

Last outbound sequence number or 0 if no outgoing message is stored.

Declaration

int OutSeqNum { get; set; }

Property Value

Type	Description
Int32	Outbound sequence number

SessionCreationTime

Time when the session attached to the storage was created.

Declaration

DateTime SessionCreationTime { get; set; }

Property Value

Type	Description
DateTime

Terminated

Session termination status.

Declaration

bool Terminated { get; set; }

Property Value

Type	Description
Boolean	`true` if the session that used this storage was terminated and the storage can be cleaned up, otherwise - `false`

Type

Declaration

SessionStorageType Type { get; }

Property Value

Type	Description
SessionStorageType

Methods

Clear()

Clears the storage state.

Inbound and outbound sequence numbers are reset to 0.

Declaration

void Clear()

Close(Boolean, Boolean)

Closes the storage.

Declaration

void Close(bool keepSequenceNumbersBetweenFixConnections, bool doBackup = false)

Parameters

Type	Name	Description
Boolean	keepSequenceNumbersBetweenFixConnections	If `true` then the session is terminated and its state information will not be used any more.
Boolean	doBackup

Flush()

Flushes all internal buffers.

Declaration

void Flush()

GetOutboundMessages(Int32, Int32)

Returns outbound messages with the specified sequence number interval. Ends are included.

Declaration

IList<IMessage> GetOutboundMessages(int beginSequenceNumber, int endSequenceNumber)

Parameters

Type	Name	Description
Int32	beginSequenceNumber	the sequence number, to begin with, `0` means the minimum available
Int32	endSequenceNumber	the sequence number, to end with, `0` means the maximum available

Returns

Type	Description
IList<IMessage>	outbound messages

StoreInboundMessage(ReadOnlySpan<Byte>, Int32, Boolean)

Stores the given inbound message.

Declaration

void StoreInboundMessage(ReadOnlySpan<byte> rawMessage, int msgSeqNum, bool isOriginal)

Parameters

Type	Name	Description
ReadOnlySpan<Byte>	rawMessage	Message to store
Int32	msgSeqNum	Message sequence number
Boolean	isOriginal

StoreOutboundMessage(ReadOnlySpan<Byte>, Int32, Boolean, Boolean, DateTime)

Stores the given outbound message.

Declaration

void StoreOutboundMessage(ReadOnlySpan<byte> rawMessage, int msgSeqNum, bool isOriginal = true, bool warmUp = false, DateTime timestamp = default(DateTime))

Parameters

Type	Name	Description
ReadOnlySpan<Byte>	rawMessage	Message to store
Int32	msgSeqNum	Message sequence number
Boolean	isOriginal
Boolean	warmUp	Indicates whether it is a warmUp message
DateTime	timestamp