BaseMessageQueue() | ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)> | protected |
CreateItem(IDataFeedConnector connector, TMessage message, Action action) | ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)> | protectedpure virtual |
Enqueue(IDataFeedConnector connector, TMessage message) | ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)> | |
Enqueue(IDataFeedConnector connector, Action action) | ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)> | |
Heartbeat | ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)> | |
HeartbeatTimeout | ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)> | |
OnProcess((IDataFeedConnector, TMessage, Action) item) | ATAS.DataFeedsCore.MultiConnectorMessageQueue< TMessage > | protected |
BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)>.OnProcess(TItem item) | ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)> | protectedpure virtual |
OnStart(IDataFeedConnector connector, Action< TMessage > handler) | ATAS.DataFeedsCore.MultiConnectorMessageQueue< TMessage > | protectedvirtual |
OnStop(IDataFeedConnector connector) | ATAS.DataFeedsCore.MultiConnectorMessageQueue< TMessage > | protectedvirtual |
override(IDataFeedConnector, TMessage, Action) CreateItem(IDataFeedConnector connector | ATAS.DataFeedsCore.MultiConnectorMessageQueue< TMessage > | protected |
Start(IDataFeedConnector connector, Action< TMessage > handler) | ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)> | |
Stop(IDataFeedConnector connector) | ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(IDataFeedConnector, TMessage, Action)> | |