ATAS.DataFeedsCore.AsyncMessageQueue< TMessage > Class Template Reference

Inheritance diagram for ATAS.DataFeedsCore.AsyncMessageQueue< TMessage >:

Collaboration diagram for ATAS.DataFeedsCore.AsyncMessageQueue< TMessage >:

Public Member Functions
	AsyncMessageQueue ()
	AsyncMessageQueue (AsyncOneThreadProcessor processor)
void	Enqueue (IDataFeedConnector connector, TMessage message)
void	Enqueue (IDataFeedConnector connector, Action action)
void	Start (IDataFeedConnector connector, Action< TMessage > handler)
void	Stop (IDataFeedConnector connector)
Public Member Functions inherited from ATAS.DataFeedsCore.IMessageQueue< TMessage >
void	Enqueue (IDataFeedConnector connector, TMessage message)
void	Enqueue (IDataFeedConnector connector, Action action)
void	EnqueueContinuation (IDataFeedConnector connector, Action continuation)
	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.
void	Start (IDataFeedConnector connector, Action< TMessage > handler)
void	Stop (IDataFeedConnector connector)

Properties
TimeSpan	HeartbeatTimeout [get, set]
Properties inherited from ATAS.DataFeedsCore.IMessageQueue< TMessage >
TimeSpan	HeartbeatTimeout [get, set]

Events
Action?	Heartbeat
Events inherited from ATAS.DataFeedsCore.IMessageQueue< TMessage >
Action?	Heartbeat

Constructor & Destructor Documentation

AsyncMessageQueue() [1/2]

ATAS.DataFeedsCore.AsyncMessageQueue< TMessage >.AsyncMessageQueue

(

)

AsyncMessageQueue() [2/2]

ATAS.DataFeedsCore.AsyncMessageQueue< TMessage >.AsyncMessageQueue

(

AsyncOneThreadProcessor

processor

)

Member Function Documentation

Enqueue() [1/2]

void ATAS.DataFeedsCore.AsyncMessageQueue< TMessage >.Enqueue	(	IDataFeedConnector	connector,
		Action	action
	)

Implements ATAS.DataFeedsCore.IMessageQueue< TMessage >.

Enqueue() [2/2]

void ATAS.DataFeedsCore.AsyncMessageQueue< TMessage >.Enqueue	(	IDataFeedConnector	connector,
		TMessage	message
	)

Implements ATAS.DataFeedsCore.IMessageQueue< TMessage >.

Start()

void ATAS.DataFeedsCore.AsyncMessageQueue< TMessage >.Start	(	IDataFeedConnector	connector,
		Action< TMessage >	handler
	)

Implements ATAS.DataFeedsCore.IMessageQueue< TMessage >.

Stop()

void ATAS.DataFeedsCore.AsyncMessageQueue< TMessage >.Stop

(

IDataFeedConnector

connector

)

Implements ATAS.DataFeedsCore.IMessageQueue< TMessage >.

Property Documentation

HeartbeatTimeout

TimeSpan ATAS.DataFeedsCore.AsyncMessageQueue< TMessage >.HeartbeatTimeout

getset

Implements ATAS.DataFeedsCore.IMessageQueue< TMessage >.

Event Documentation

Heartbeat

Action? ATAS.DataFeedsCore.AsyncMessageQueue< TMessage >.Heartbeat

---

The documentation for this class was generated from the following file:

• IMessageQueue.cs