AddExchange(String Exchange) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
AddFilterElement(FilterElement filterElement, params FilterElement[] filterElements) (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
AddFilterElement(FilterElement filterElement) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
AddInstrument(String instrument) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
AddInstruments(InstrumentList instruments) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
AsyncServiceCallCallback(AsyncServiceCallResult result) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inlinevirtual |
consumer (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | protected |
ConsumerStartedCallback(TcpConsumer consumer) (defined in Gevasys.DataCore.Client.Consumer.Tcp.TcpConsumerManager) | Gevasys.DataCore.Client.Consumer.Tcp.TcpConsumerManager | inline |
exchanges (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | protected |
filterElements (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | protected |
FireConsumerStateChangedEvent(ConsumerStateChangedEventArgs e) (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inlineprotected |
GetConsumer() (defined in Gevasys.DataCore.Client.Consumer.Tcp.TcpConsumerManager) | Gevasys.DataCore.Client.Consumer.Tcp.TcpConsumerManager | inline |
GetConsumerType() | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
GetExchanges() (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
GetInstruments() | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
GetIsAlive() | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
GetIsBackup() | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
GetName() | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
GetPushClient() | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
instruments (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | protected |
oldAlive (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | protected |
OnConsumerStateChanged (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | |
pendingExchangeSubscribesForConsumer (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | protected |
pendingFilterElementsSubscribesForConsumer (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | protected |
pendingRecapsForConsumer (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | protected |
pendingSubscribesForConsumer (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | protected |
pushClient (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | protected |
RecapPendingInstrumentsForConsumer(IStreamingConsumer consumer, InstrumentList instruments) (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inlineprotected |
RemoveAll() | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
RemoveExchange(String Exchange) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
RemoveFieldFilter() | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
RemoveFilterElement(FilterElement filterElement) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
RemoveFilterElement(FilterElement filterElement, params FilterElement[] filterElements) (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
RemoveInstrument(String instrument) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
RemoveInstruments(InstrumentList instruments) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
RequestRecaps(InstrumentList instruments) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
SetAsBackup(bool isBackup) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
SetFieldFilter(List< string > fieldList) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
SetOffline() (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
SetOnline() (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
SignalConsumerAborted(TcpConsumer consumer, Error.ConsumerError error) (defined in Gevasys.DataCore.Client.Consumer.Tcp.TcpConsumerManager) | Gevasys.DataCore.Client.Consumer.Tcp.TcpConsumerManager | inline |
SignalConsumerAborted(TcpConsumer consumer, ConsumerError error) (defined in Gevasys.DataCore.Client.Consumer.Tcp.ITcpConsumerManager) | Gevasys.DataCore.Client.Consumer.Tcp.ITcpConsumerManager | |
Start() | Gevasys.DataCore.Client.Consumer.Tcp.TcpConsumerManager | inlinevirtual |
Stop() | Gevasys.DataCore.Client.Consumer.Tcp.TcpConsumerManager | inlinevirtual |
StreamingConsumerManager(IPushClient pushClient, String name) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
SubscribeNewsBroadcast() (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
SubscribePendingExchangesForConsumer(IStreamingConsumer consumer, List< string > exchanges) (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inlineprotected |
SubscribePendingFilterElementsForConsumer(IStreamingConsumer consumer, List< FilterElement > filterElements) (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inlineprotected |
SubscribePendingInstrumentsForConsumer(IStreamingConsumer consumer, InstrumentList instruments) (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inlineprotected |
TcpConsumerManager(String parentManagerName, IPushClient pushClient, String wsdl, String requestedName, String name, Proxy_Nillable proxy) (defined in Gevasys.DataCore.Client.Consumer.Tcp.TcpConsumerManager) | Gevasys.DataCore.Client.Consumer.Tcp.TcpConsumerManager | inline |
UnsubscribeNewsBroadcast() (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |
Update(IConsumer source, ConsumerStateChangedEventArgs arg) (defined in Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager) | Gevasys.DataCore.Consumer.Manager.StreamingConsumerManager | inline |