ATAS.DataFeedsCore.SimpleMessageQueue< TMessage > Class Template Reference

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

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

Protected Member Functions
	override (TMessage? Message, Action? Action) CreateItem(IDataFeedConnector connector
override void	OnStart (IDataFeedConnector connector, Action< TMessage > handler)
override bool	OnStop (IDataFeedConnector connector)
override void	OnProcess ((TMessage? Message, Action? Action) item)
override? object	DescribeItem ((TMessage? Message, Action? Action) item)
Protected Member Functions inherited from ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(TMessage? Message, Action? 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,(TMessage? Message, Action? 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,(TMessage? Message, Action? Action)>
TimeSpan	HeartbeatTimeout [get, set]
Events inherited from ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(TMessage? Message, Action? Action)>
Action?	Heartbeat

Member Function Documentation

DescribeItem()

override? object ATAS.DataFeedsCore.SimpleMessageQueue< TMessage >.DescribeItem ( (TMessage? Message, Action? Action)  item )

protected

OnProcess()

override void ATAS.DataFeedsCore.SimpleMessageQueue< TMessage >.OnProcess ( (TMessage? Message, Action? Action)  item )

protected

OnStart()

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

protectedvirtual

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

OnStop()

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

protectedvirtual

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

override()

ATAS.DataFeedsCore.SimpleMessageQueue< TMessage >.override ( TMessage?  Message, Action?  Action  )

protected

---

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

• IMessageQueue.cs