Represents a manger that manages a IStreamingConsumer. This class handles offline and online states for the managed streaming consumer as well as lazy subscribe of instruments and fail over.
More...
Inherits Gevasys.DataCore.Consumer.Manager.IStreamingConsumerManager.
Inherited by Gevasys.DataCore.Client.Consumer.Tcp.TcpConsumerManager.
|
|
readonly InstrumentList | instruments |
| |
|
readonly List< string > | exchanges |
| |
|
readonly List< FilterElement > | filterElements |
| |
|
readonly List< FilterElement > | pendingFilterElementsSubscribesForConsumer |
| |
|
readonly InstrumentList | pendingSubscribesForConsumer |
| |
|
readonly List< String > | pendingExchangeSubscribesForConsumer |
| |
|
readonly InstrumentList | pendingRecapsForConsumer |
| |
|
IPushClient | pushClient |
| |
|
StreamingConsumer | consumer |
| |
|
bool | oldAlive = false |
| |
Represents a manger that manages a IStreamingConsumer. This class handles offline and online states for the managed streaming consumer as well as lazy subscribe of instruments and fail over.
◆ StreamingConsumerManager()
| Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.StreamingConsumerManager |
( |
IPushClient |
pushClient, |
|
|
String |
name |
|
) |
| |
|
inline |
Initializes a new instance of the StreamingConsumerManager class.
- Parameters
-
| pushClient | A instance of a IPushClient that will be attached to this manager. |
| name | The name of the manager. |
◆ AddExchange()
| void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.AddExchange |
( |
String |
Exchange | ) |
|
|
inline |
Adds and subscribes a exchange.
- Parameters
-
<font color="#3F5FBF" size="2"> <font color="#3F5FBF" size="2">Not available in version 1.1.</font> </font>
Implements Gevasys.DataCore.Core.IConsumer.
◆ AddFilterElement()
| void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.AddFilterElement |
( |
FilterElement |
filterElement | ) |
|
|
inline |
◆ AddInstrument()
| void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.AddInstrument |
( |
String |
instrument | ) |
|
|
inline |
◆ AddInstruments()
| void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.AddInstruments |
( |
InstrumentList |
instruments | ) |
|
|
inline |
◆ AsyncServiceCallCallback()
| virtual void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.AsyncServiceCallCallback |
( |
AsyncServiceCallResult |
result | ) |
|
|
inlinevirtual |
◆ GetConsumerType()
| ConsumerType Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.GetConsumerType |
( |
| ) |
|
|
inline |
◆ GetInstruments()
| InstrumentList Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.GetInstruments |
( |
| ) |
|
|
inline |
◆ GetIsAlive()
| bool Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.GetIsAlive |
( |
| ) |
|
|
inline |
◆ GetIsBackup()
| bool Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.GetIsBackup |
( |
| ) |
|
|
inline |
◆ GetName()
| String Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.GetName |
( |
| ) |
|
|
inline |
◆ GetPushClient()
| IPushClient Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.GetPushClient |
( |
| ) |
|
|
inline |
◆ RemoveAll()
| void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.RemoveAll |
( |
| ) |
|
|
inline |
◆ RemoveExchange()
| void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.RemoveExchange |
( |
String |
Exchange | ) |
|
|
inline |
Removes and unsubscribes a exchange.
<font color="#3F5FBF" size="2"> <font color="#3F5FBF" size="2">Available from version 2.x</font> </font>
Implements Gevasys.DataCore.Core.IConsumer.
◆ RemoveFieldFilter()
| void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.RemoveFieldFilter |
( |
| ) |
|
|
inline |
Removes a field filter.
<font color="#3F5FBF" size="2"> <font color="#3F5FBF" size="2">Available from Version 2.x.</font> </font>
Implements Gevasys.DataCore.Core.IConsumer.
◆ RemoveFilterElement()
| void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.RemoveFilterElement |
( |
FilterElement |
filterElement | ) |
|
|
inline |
◆ RemoveInstrument()
| void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.RemoveInstrument |
( |
String |
instrument | ) |
|
|
inline |
◆ RemoveInstruments()
| void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.RemoveInstruments |
( |
InstrumentList |
instruments | ) |
|
|
inline |
Remove and unsubscribes a list of instruments.
- Parameters
-
| instruments | <font color="#3F5FBF" size="2"> <font color="#3F5FBF" size="2">The list of Instruments</font> </font> |
Implements Gevasys.DataCore.Core.IConsumer.
◆ RequestRecaps()
| void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.RequestRecaps |
( |
InstrumentList |
instrumentList | ) |
|
|
inline |
◆ SetAsBackup()
| void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.SetAsBackup |
( |
bool |
isBackup | ) |
|
|
inline |
◆ SetFieldFilter()
| void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.SetFieldFilter |
( |
List< string > |
fieldList | ) |
|
|
inline |
Sets a list of fields as a data filter for the streaming connection on the server side. Only fields that exists in the field filter will be pushed.
- Parameters
-
<font color="#3F5FBF" size="2"> <font color="#3F5FBF" size="2">Available from Version 2.x.</font> </font>
Implements Gevasys.DataCore.Core.IConsumer.
◆ Start()
| virtual bool Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.Start |
( |
| ) |
|
|
inlinevirtual |
◆ Stop()
| virtual void Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager.Stop |
( |
| ) |
|
|
inlinevirtual |
The documentation for this class was generated from the following file:
- StreamingConsumerManager.cs