ATAS.DataFeedsCore.MultiConnectorMessageQueue< TMessage > Class Template Reference

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

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

Protected Member Functions
	override (IDataFeedConnector, TMessage, Action) CreateItem(IDataFeedConnector connector
override void	OnStart (IDataFeedConnector connector, Action< TMessage > handler)
override bool	OnStop (IDataFeedConnector connector)
override void	OnProcess ((IDataFeedConnector, TMessage, Action) item)
override? object	DescribeItem ((IDataFeedConnector, TMessage, Action) item)
Protected Member Functions inherited from ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)>
	BaseMessageQueue ()
abstract TItem	CreateItem (IDataFeedConnector connector, TMessage message, Action action)
abstract void	OnStart (IDataFeedConnector connector, Action< TMessage > handler)
abstract bool	OnStop (IDataFeedConnector connector)
abstract void	OnProcess (TItem item)
virtual ? object	DescribeItem (TItem item)
	Short representation of a queued item for debug logging. Full message dumps are logged by connectors on receive; dumping them again here would double the cost.

Additional Inherited Members
Public Member Functions inherited from ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)>
void	Enqueue (IDataFeedConnector connector, TMessage message)
void	Enqueue (IDataFeedConnector connector, Action action)
void	Start (IDataFeedConnector connector, Action< TMessage > handler)
void	Stop (IDataFeedConnector connector)
Properties inherited from ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)>
TimeSpan	HeartbeatTimeout [get, set]
Events inherited from ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)>
Action	Heartbeat

Member Function Documentation

DescribeItem()

override? object ATAS.DataFeedsCore.MultiConnectorMessageQueue< TMessage >.DescribeItem ( (IDataFeedConnector, TMessage, Action)  item )

protected

OnProcess()

override void ATAS.DataFeedsCore.MultiConnectorMessageQueue< TMessage >.OnProcess ( (IDataFeedConnector, TMessage, Action)  item )

protected

OnStart()

override void ATAS.DataFeedsCore.MultiConnectorMessageQueue< TMessage >.OnStart ( IDataFeedConnector  connector, Action< TMessage >  handler  )

protectedvirtual

Implements ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)>.

OnStop()

override bool ATAS.DataFeedsCore.MultiConnectorMessageQueue< TMessage >.OnStop ( IDataFeedConnector  connector )

protectedvirtual

Implements ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)>.

override()

ATAS.DataFeedsCore.MultiConnectorMessageQueue< TMessage >.override ( IDataFeedConnector  , TMessage  , Action    )

protected

---

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

• IMessageQueue.cs