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)
void	Enqueue (IDataFeedConnector connector, TMessage message)
void	Enqueue (IDataFeedConnector connector, Action 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