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, Action) CreateItem(IDataFeedConnector connector
override void	OnStart (IDataFeedConnector connector, Action< TMessage > handler)
override bool	OnStop (IDataFeedConnector connector)
override void	OnProcess ((TMessage, Action) item)
Protected Member Functions inherited from ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(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)

Additional Inherited Members
Public Member Functions inherited from ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(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,(TMessage, Action)>
TimeSpan	HeartbeatTimeout [get, set]
Events inherited from ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(TMessage, Action)>
Action	Heartbeat

Member Function Documentation

OnProcess()

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

protected

OnStart()

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

protectedvirtual

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

OnStop()

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

protectedvirtual

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

override()

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

protected

---

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

• IMessageQueue.cs