ATAS.DataFeedsCore.BaseMessageQueue< TMessage, TItem > Class Template Reference

Inheritance diagram for ATAS.DataFeedsCore.BaseMessageQueue< TMessage, TItem >:

Collaboration diagram for ATAS.DataFeedsCore.BaseMessageQueue< TMessage, TItem >:

Public Member Functions
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)

Protected Member Functions
	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)

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

BaseMessageQueue()

ATAS.DataFeedsCore.BaseMessageQueue< TMessage, TItem >.BaseMessageQueue ( )

protected

Member Function Documentation

CreateItem()

abstract TItem ATAS.DataFeedsCore.BaseMessageQueue< TMessage, TItem >.CreateItem ( IDataFeedConnector  connector, TMessage  message, Action  action  )

protectedpure virtual

Enqueue() [1/2]

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

Implements ATAS.DataFeedsCore.IMessageQueue< TMessage >.

Enqueue() [2/2]

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

Implements ATAS.DataFeedsCore.IMessageQueue< TMessage >.

OnProcess()

abstract void ATAS.DataFeedsCore.BaseMessageQueue< TMessage, TItem >.OnProcess ( TItem  item )

protectedpure virtual

OnStart()

abstract void ATAS.DataFeedsCore.BaseMessageQueue< TMessage, TItem >.OnStart ( IDataFeedConnector  connector, Action< TMessage >  handler  )

protectedpure virtual

Implemented in ATAS.DataFeedsCore.SimpleMessageQueue< TMessage >, and ATAS.DataFeedsCore.MultiConnectorMessageQueue< TMessage >.

OnStop()

abstract bool ATAS.DataFeedsCore.BaseMessageQueue< TMessage, TItem >.OnStop ( IDataFeedConnector  connector )

protectedpure virtual

Implemented in ATAS.DataFeedsCore.SimpleMessageQueue< TMessage >, and ATAS.DataFeedsCore.MultiConnectorMessageQueue< TMessage >.

Start()

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

Implements ATAS.DataFeedsCore.IMessageQueue< TMessage >.

Stop()

void ATAS.DataFeedsCore.BaseMessageQueue< TMessage, TItem >.Stop

(

IDataFeedConnector

connector

)

Implements ATAS.DataFeedsCore.IMessageQueue< TMessage >.

Property Documentation

HeartbeatTimeout

TimeSpan ATAS.DataFeedsCore.BaseMessageQueue< TMessage, TItem >.HeartbeatTimeout

getset

Implements ATAS.DataFeedsCore.IMessageQueue< TMessage >.

Event Documentation

Heartbeat

Action ATAS.DataFeedsCore.BaseMessageQueue< TMessage, TItem >.Heartbeat

---

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

• IMessageQueue.cs