ATAS
Loading...
Searching...
No Matches
ATAS.DataFeedsCore.SimpleMessageQueue< TMessage > Class Template Reference
Inheritance diagram for ATAS.DataFeedsCore.SimpleMessageQueue< TMessage >:
[legend]
Collaboration diagram for ATAS.DataFeedsCore.SimpleMessageQueue< TMessage >:
[legend]

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

◆ OnStop()

◆ override()

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

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