Class StandardSessionSequenceManager
Inheritance
System.Object
StandardSessionSequenceManager
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()
Assembly: FixAntenna.Core.dll
Syntax
public class StandardSessionSequenceManager : ISessionSequenceManager
Constructors
StandardSessionSequenceManager(AbstractFixSession)
Declaration
public StandardSessionSequenceManager(AbstractFixSession session)
Parameters
Fields
Log
Declaration
protected static readonly ILog Log
Field Value
Methods
ApplyInSeqNum(Int64)
Declaration
public virtual void ApplyInSeqNum(long inSeqNum)
Parameters
| Type |
Name |
Description |
| System.Int64 |
inSeqNum |
|
ApplyOutSeqnum(Int64)
Declaration
public virtual void ApplyOutSeqnum(long outSeqNum)
Parameters
| Type |
Name |
Description |
| System.Int64 |
outSeqNum |
|
Declaration
public virtual void ConfigureStateBeforeReset()
CreateSessionParameters()
Declaration
public virtual SessionParameters CreateSessionParameters()
Returns
DecrementIncomingSeqNumber()
Declaration
public virtual void DecrementIncomingSeqNumber()
DoAfterMessageProcessActions()
Declaration
public virtual bool DoAfterMessageProcessActions()
Returns
| Type |
Description |
| System.Boolean |
|
GetCountOfSentRequests(Int64, Int64)
Declaration
public virtual long GetCountOfSentRequests(long startRange, long endRange)
Parameters
| Type |
Name |
Description |
| System.Int64 |
startRange |
|
| System.Int64 |
endRange |
|
Returns
| Type |
Description |
| System.Int64 |
|
GetEndRangeOfRrSequence()
Declaration
public virtual long GetEndRangeOfRrSequence()
Returns
| Type |
Description |
| System.Int64 |
end of range or -1
|
GetExpectedIncomingSeqNumber()
Gets expected sequence number.
If in the session LastRrSeqNum attribute is set the seq number takes from it;
Otherwise if processed seq number is set in the session parameters the expected seq num takes from it;
Otherwise the seq number takes from incoming seq num.
Declaration
public virtual long GetExpectedIncomingSeqNumber()
Returns
| Type |
Description |
| System.Int64 |
|
GetRrSequenceFromSession()
Gets RR sequence from session attribute.
Declaration
public virtual long GetRrSequenceFromSession()
Returns
| Type |
Description |
| System.Int64 |
RR num or null.
|
GetSeqResendManager()
Gets sequence resend manager.
Declaration
public virtual ISequenceResendManager GetSeqResendManager()
Returns
GetSessionParametersForSaving(SessionParameters)
Declaration
public virtual SessionParameters GetSessionParametersForSaving(SessionParameters sessionParameters)
Parameters
Returns
GetStartRangeOfRrSequence()
Declaration
public virtual long GetStartRangeOfRrSequence()
Returns
| Type |
Description |
| System.Int64 |
start of range or -1
|
IncrementOutSeqNum()
Declaration
public virtual void IncrementOutSeqNum()
InitLastSeqNumResetTimestampOnNewSession()
Declaration
public virtual void InitLastSeqNumResetTimestampOnNewSession()
InitSeqNums(Int64, Int64)
Declaration
public virtual void InitSeqNums(long inStorageSeqNum, long nextOutStorageSeqNum)
Parameters
| Type |
Name |
Description |
| System.Int64 |
inStorageSeqNum |
|
| System.Int64 |
nextOutStorageSeqNum |
|
IsResetTimeMissed(Int64)
Declaration
public virtual bool IsResetTimeMissed(long lastResetTime)
Parameters
| Type |
Name |
Description |
| System.Int64 |
lastResetTime |
|
Returns
| Type |
Description |
| System.Boolean |
|
IsRRangeExists()
Returns true if range exists.
Declaration
public virtual bool IsRRangeExists()
Returns
| Type |
Description |
| System.Boolean |
|
IsRrSequenceActive()
Declaration
public virtual bool IsRrSequenceActive()
Returns
| Type |
Description |
| System.Boolean |
|
IsSequenceInRange(Int64)
Returns true if seqNum in range.
Declaration
public virtual bool IsSequenceInRange(long seqNum)
Parameters
| Type |
Name |
Description |
| System.Int64 |
seqNum |
|
Returns
| Type |
Description |
| System.Boolean |
|
LoadStoredParameters()
Loads sequences from file.
Declaration
public virtual void LoadStoredParameters()
Reinit(AbstractFixSession)
Declaration
public virtual void Reinit(AbstractFixSession session)
Parameters
RemoveRangeOfRrSequence()
Declaration
public virtual void RemoveRangeOfRrSequence()
RemoveRrSequenceFromSession(Nullable<Int64>)
Remove RR seq from session.
Declaration
public virtual void RemoveRrSequenceFromSession(long? lastSeqId)
Parameters
| Type |
Name |
Description |
| System.Nullable<System.Int64> |
lastSeqId |
|
RequestLostMessages(Int64, Int64, Boolean)
Declaration
public virtual void RequestLostMessages(long expectedSeqNum, long incomingSeqNum, bool posDup)
Parameters
| Type |
Name |
Description |
| System.Int64 |
expectedSeqNum |
|
| System.Int64 |
incomingSeqNum |
|
| System.Boolean |
posDup |
|
ResetSeqNumForNextConnect()
Declaration
public virtual void ResetSeqNumForNextConnect()
ResetSequencesOnLogon()
Declaration
public virtual void ResetSequencesOnLogon()
ResetSequencesOnRequest(Int64)
Declaration
public virtual void ResetSequencesOnRequest(long msgSeqNum)
Parameters
| Type |
Name |
Description |
| System.Int64 |
msgSeqNum |
|
RestoreSessionParameters()
Declaration
public virtual void RestoreSessionParameters()
SaveProcessedSeqNumberOnShutdown()
Store the last processed seq number.
The method work only when last processed and last incoming seq nums are not equals.
Declaration
public virtual void SaveProcessedSeqNumberOnShutdown()
SaveRestoredSequences()
Restore session parameters file.
Declaration
public virtual void SaveRestoredSequences()
Exceptions
| Type |
Condition |
| System.IO.IOException |
if error occurred
|
SaveRrSequence(Int64)
Declaration
public virtual void SaveRrSequence(long lastRrSeq)
Parameters
| Type |
Name |
Description |
| System.Int64 |
lastRrSeq |
the resend request sequence
|
Exceptions
| Type |
Condition |
| System.IO.IOException |
if error occurred
|
SaveSessionParameters()
Save session parameters in file.
If session attribute LastRrSeqNum is set the incoming seq num will be saved;
And if sessionParameters.GetProcessedIncomingSequenceNumber() is set the last processed seq num will be saved;
Declaration
public virtual void SaveSessionParameters()
Exceptions
| Type |
Condition |
| System.IO.IOException |
if error occurred
|
SetResetSeqNumFlagIntoOutgoingLogon()
Declaration
public virtual void SetResetSeqNumFlagIntoOutgoingLogon()
SetSessionParametersOverrides(SessionParameters, SessionParameters)
Declaration
public virtual void SetSessionParametersOverrides(SessionParameters sessionParameters, SessionParameters inParameters)
Parameters
UpdateEndOfRrRange(Int64)
Declaration
public virtual void UpdateEndOfRrRange(long incomingSeqNum)
Parameters
| Type |
Name |
Description |
| System.Int64 |
incomingSeqNum |
|
UpdateLastRrSequence(Nullable<Int64>)
Declaration
public virtual void UpdateLastRrSequence(long? msgSeqNum)
Parameters
| Type |
Name |
Description |
| System.Nullable<System.Int64> |
msgSeqNum |
|
Implements