Interface IMessageQueue<TMessage>

Namespace

ATAS.DataFeedsCore

Assembly

ATAS.DataFeedsCore.dll

The queue that serializes the processing of a connector: the messages and actions put into it are processed one by one by the connector's thread, and the messages are passed to the handler registered by Start(IDataFeedConnector, Action<TMessage>). BaseConnector<TMessage, TPortfolioKey, TSecurityKey, TSecurityPositionManager> starts the queue when it connects and stops it when it ends up disconnected.

public interface IMessageQueue<TMessage> : ILoggerSource

Type Parameters

TMessage

The type of the connector's messages.

Inherited Members

ILoggerSource.LoggerId

ILoggerSource.LoggerName

ILoggerSource.LoggingLevel

ILoggerSource.ParentLoggerSource

ILoggerSource.ChildLoggerSources

ILoggerSource.LoggerSettingsChanged

Extension Methods

Extensions.ConvertToMyTrade<T>(T, Portfolio, Security, Action<MyTrade, T>)

LoggerHelper.DisposeLogger(object)

LoggerHelper.LogDebug(object, string, params object?[])

LoggerHelper.LogError(object, string, Exception, bool)

LoggerHelper.LogError(object, string, params object?[])

LoggerHelper.LogFatal(object, string, Exception, bool)

LoggerHelper.LogInfo(object, string, params object?[])

LoggerHelper.LogWarn(object, string, params object?[])

Properties

HeartbeatTimeout

Interval of the Heartbeat event; System.TimeSpan.Zero disables it. The connector sets it before it starts the queue.

TimeSpan HeartbeatTimeout { get; set; }

Property Value

TimeSpan

Methods

Enqueue(IDataFeedConnector, Action)

Queues an action to run on the connector's thread.

void Enqueue(IDataFeedConnector connector, Action action)

Parameters

connector IDataFeedConnector

The connector the action belongs to.

action Action

The action.

Enqueue(IDataFeedConnector, TMessage)

Queues a message of the connector for its handler.

void Enqueue(IDataFeedConnector connector, TMessage message)

Parameters

connector IDataFeedConnector

The connector the message belongs to.

message TMessage

The message.

EnqueueContinuation(IDataFeedConnector, Action)

Queues an await continuation of the connector's thread (the connector's synchronization context).
A continuation belongs to the connection session it was posted in: once that session has ended (the connector's final disconnect stopped the queue), it must not run in a later one - it would resume the code of an abandoned connect attempt or of a closed connection inside the new connection (complete the new attempt, start transports, process stale data). Unlike a message queued while the connector is disconnected, which waits for the next connect, a continuation posted after its session ended is dropped.
The default implementation queues it as an ordinary action.

Not in ATAS 8.0.15 yet: available from the next version.

void EnqueueContinuation(IDataFeedConnector connector, Action continuation)

Parameters

connector IDataFeedConnector

continuation Action

Start(IDataFeedConnector, Action<TMessage>)

Starts processing for the connector: its messages go to the handler from now on. Called when the connector starts connecting.

void Start(IDataFeedConnector connector, Action<TMessage> handler)

Parameters

connector IDataFeedConnector

The connector.

handler Action<TMessage>

Processes a message of the connector on the queue's thread.

Stop(IDataFeedConnector)

Stops processing for the connector. Called when the connector ends up disconnected (not on a connection loss that is followed by a reconnection).

void Stop(IDataFeedConnector connector)

Parameters

connector IDataFeedConnector

The connector.

Events

Heartbeat

Raised on the queue's thread every HeartbeatTimeout while the queue runs.

Added in ATAS 8.0.15.

event Action? Heartbeat

Event Type

Action