Class MessageReader

The MessageReader reads message from transport.

Inheritance
System.Object
AffinitySupportThread
MessageReader
Implements
System.IDisposable
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.Session.IOThreads
Assembly: FixAntenna.Core.dll
Syntax
public sealed class MessageReader : AffinitySupportThread, IDisposable, IMessageReader, IWorkerThread

Constructors

MessageReader(IExtendedFixSession, IMessageStorage, ICompositeMessageHandlerListener, IFixTransport, IEncryption)

Creates MessageReader.

Declaration
public MessageReader(IExtendedFixSession session, IMessageStorage messageStorage, ICompositeMessageHandlerListener compositeFixSessionListener, IFixTransport transport, IEncryption encryption)
Parameters
Type Name Description
IExtendedFixSession session

the session
IMessageStorage messageStorage

the message storage
ICompositeMessageHandlerListener compositeFixSessionListener

the session listener
IFixTransport transport

the transport
IEncryption encryption

Methods

CloseStorage()

Declaration
public void CloseStorage()

Dispose(Boolean)

Declaration
protected override void Dispose(bool disposing)
Parameters
Type Name Description
System.Boolean disposing
Overrides

GetIncomingMessageStorage()

Gets incoming message storage.

Declaration
public IMessageStorage GetIncomingMessageStorage()
Returns
Type Description
IMessageStorage

GetMessageProcessedTimestamp()

Declaration
public long GetMessageProcessedTimestamp()
Returns
Type Description
System.Int64

GetMessageStatistic()

Gets statistic of processed messages. WARNING: Before the call to ensure that the statistics are included.

Declaration
public MessageStatistic GetMessageStatistic()
Returns
Type Description
MessageStatistic

MessageStatistic
Exceptions
Type Condition
System.InvalidOperationException

if statisticEnabled is false
See Also

Init(ConfigurationAdaptor)

Declaration
public long Init(ConfigurationAdaptor configurationAdapter)
Parameters
Type Name Description
ConfigurationAdaptor configurationAdapter
Returns
Type Description
System.Int64

IsStatisticEnabled()

Declaration
public bool IsStatisticEnabled()
Returns
Type Description
System.Boolean

true is statistic is enabled

Run()

Declaration
protected override void Run()
Overrides

SetGracefulShutdown(Boolean)

Sets graceful shutdown flag.

Declaration
public void SetGracefulShutdown(bool gracefulShutdown)
Parameters
Type Name Description
System.Boolean gracefulShutdown

the graceful shutdown flag

SetMessageProcessedTimestamp(Int64)

Declaration
public void SetMessageProcessedTimestamp(long timestamp)
Parameters
Type Name Description
System.Int64 timestamp

Shutdown()

Shutdown the reader.

Declaration
public override void Shutdown()
Overrides

Implements

System.IDisposable

See Also