ATAS
Loading...
Searching...
No Matches
ATAS.DataFeedsCore.SimpleMessageQueue< TMessage > Member List

This is the complete list of members for ATAS.DataFeedsCore.SimpleMessageQueue< TMessage >, including all inherited members.

BaseMessageQueue()ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(TMessage, Action)>protected
CreateItem(IDataFeedConnector connector, TMessage message, Action action)ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(TMessage, Action)>protectedpure virtual
Enqueue(IDataFeedConnector connector, TMessage message)ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(TMessage, Action)>
Enqueue(IDataFeedConnector connector, Action action)ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(TMessage, Action)>
HeartbeatATAS.DataFeedsCore.BaseMessageQueue< TMessage,(TMessage, Action)>
HeartbeatTimeoutATAS.DataFeedsCore.BaseMessageQueue< TMessage,(TMessage, Action)>
OnProcess((TMessage, Action) item)ATAS.DataFeedsCore.SimpleMessageQueue< TMessage >protected
BaseMessageQueue< TMessage,(TMessage, Action)>.OnProcess(TItem item)ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(TMessage, Action)>protectedpure virtual
OnStart(IDataFeedConnector connector, Action< TMessage > handler)ATAS.DataFeedsCore.SimpleMessageQueue< TMessage >protectedvirtual
OnStop(IDataFeedConnector connector)ATAS.DataFeedsCore.SimpleMessageQueue< TMessage >protectedvirtual
override(TMessage, Action) CreateItem(IDataFeedConnector connectorATAS.DataFeedsCore.SimpleMessageQueue< TMessage >protected
Start(IDataFeedConnector connector, Action< TMessage > handler)ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(TMessage, Action)>
Stop(IDataFeedConnector connector)ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(TMessage, Action)>