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

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

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