| 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)> | |
| Heartbeat | ATAS.DataFeedsCore.BaseMessageQueue< TMessage,(TMessage, Action)> | |
| HeartbeatTimeout | ATAS.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 connector | ATAS.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)> | |