ATAS
|
Public Member Functions | |
void | Enqueue (IDataFeedConnector connector, TMessage message) |
void | Enqueue (IDataFeedConnector connector, Action action) |
void | Start (IDataFeedConnector connector, Action< TMessage > handler) |
void | Stop (IDataFeedConnector connector) |
Properties | |
TimeSpan | HeartbeatTimeout [get, set] |
Events | |
Action | Heartbeat |
void ATAS.DataFeedsCore.IMessageQueue< TMessage >.Enqueue | ( | IDataFeedConnector | connector, |
Action | action | ||
) |
void ATAS.DataFeedsCore.IMessageQueue< TMessage >.Enqueue | ( | IDataFeedConnector | connector, |
TMessage | message | ||
) |
void ATAS.DataFeedsCore.IMessageQueue< TMessage >.Start | ( | IDataFeedConnector | connector, |
Action< TMessage > | handler | ||
) |
void ATAS.DataFeedsCore.IMessageQueue< TMessage >.Stop | ( | IDataFeedConnector | connector | ) |
|
getset |
Action ATAS.DataFeedsCore.IMessageQueue< TMessage >.Heartbeat |