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