ConnectorSubscriptionManager

ConnectorSubscriptionManager

public ConnectorSubscriptionManager(ILogReceiver logReceiver, IdGenerator transactionIdGenerator, bool sendUnsubscribeWhenDisconnected)

connectorSubscriptionManager = ConnectorSubscriptionManager(logReceiver, transactionIdGenerator, sendUnsubscribeWhenDisconnected)

Verwaltet Abonnements und deren Lebenszyklus.

logReceiver

Protokollempfänger.

transactionIdGenerator

Transaktions-ID-Generator.

sendUnsubscribeWhenDisconnected

Gibt an, ob Abmeldeanfragen gesendet werden sollen, während die Verbindung getrennt ist.

ConnectionState

public ConnectionStates ConnectionState { get; set; }

value = connectorSubscriptionManager.ConnectionState
connectorSubscriptionManager.ConnectionState = value

Aktueller Anschlusszustand.

IsRestoreSubscriptionOnNormalReconnect

public bool IsRestoreSubscriptionOnNormalReconnect { get; set; }

value = connectorSubscriptionManager.IsRestoreSubscriptionOnNormalReconnect
connectorSubscriptionManager.IsRestoreSubscriptionOnNormalReconnect = value

Restore-Abonnement bei Reconnect.

SendUnsubscribeWhenDisconnected

public bool SendUnsubscribeWhenDisconnected { get; }

value = connectorSubscriptionManager.SendUnsubscribeWhenDisconnected

Gibt an, ob Abmeldeanfragen gesendet werden sollen, während die Verbindung getrennt ist.

Subscriptions

public IEnumerable<Subscription> Subscriptions { get; }

value = connectorSubscriptionManager.Subscriptions

Aktuelle Abonnements Snapshot.

SubscriptionsOnConnect

public CachedSynchronizedSet<Subscription> SubscriptionsOnConnect { get; }

value = connectorSubscriptionManager.SubscriptionsOnConnect

Senden Sie Abonnements auf connect.

TransactionIdGenerator

public IdGenerator TransactionIdGenerator { get; set; }

value = connectorSubscriptionManager.TransactionIdGenerator
connectorSubscriptionManager.TransactionIdGenerator = value

Transaktions-ID-Generator.

ClearCache

public void ClearCache()

connectorSubscriptionManager.ClearCache()

Klarer interner Zustand.

GetSubscribers

public IEnumerable<SecurityId> GetSubscribers(DataType dataType)

result = connectorSubscriptionManager.GetSubscribers(dataType)

Erhalten Sie Finanzinstrumente, die aktive Abonnements für den angegebenen Datentyp haben.

dataType

Datenart.

Rückgabe: Finanzinstrumente mit aktiven Zeichnungen.

GetSubscriptions

public IEnumerable<Subscription> GetSubscriptions(ISubscriptionIdMessage message)

result = connectorSubscriptionManager.GetSubscriptions(message)

Lösen Sie Abonnements für die angegebene Nachricht.

message

Nachricht mit Abonnement-IDs.

Rückgabe: Abonnements.

HandleConnected

public Actions HandleConnected(Subscription[] subscriptions)

result = connectorSubscriptionManager.HandleConnected(subscriptions)

Behandeln Sie Verbindungsereignisse und stellen Sie Abonnements nach Bedarf wieder her.

subscriptions

Standard-Abonnements.

Rückgabe: Anwendbare Maßnahmen.

HandleConnected

public Actions HandleConnected(Func<Subscription, bool> subscriptionFilter)

result = connectorSubscriptionManager.HandleConnected(subscriptionFilter)

Behandeln Sie Verbindungsereignisse und stellen Sie Abonnements nach Bedarf wieder her.

subscriptionFilter

Filtern Sie nach SubscriptionsOnConnect.

Rückgabe: Anwendbare Maßnahmen.

ProcessLookupResponse``1

public IEnumerable<Subscription> ProcessLookupResponse<T>(ISubscriptionIdMessage message, T item)

result = connectorSubscriptionManager.ProcessLookupResponse(message, item)

Verarbeiten Sie ein Lookup Response Item.

message

Lookup-Nachricht.

item

Lookup Item.

Rückgabe: Abonnements, die den Artikel erhalten haben.

ProcessResponse

public Subscription ProcessResponse(SubscriptionResponseMessage response, ISubscriptionMessage originalMsg, bool unexpectedCancelled, Object[] items)

result = connectorSubscriptionManager.ProcessResponse(response, originalMsg, unexpectedCancelled, items)

Verarbeiten Sie eine Subscription Response Message.

response

Antwortmeldung.

originalMsg

Original-Abonnement-Anfrage.

unexpectedCancelled

Gibt an, dass das aktive Abonnement aufgrund eines Fehlers gekündigt wurde.

items

Gesammelte Lookup-Artikel.

Rückgabe: Subscription-Instanz.

ProcessSubscriptionFinishedMessage

public Subscription ProcessSubscriptionFinishedMessage(SubscriptionFinishedMessage message, Object[] items)

result = connectorSubscriptionManager.ProcessSubscriptionFinishedMessage(message, items)

Verarbeiten Sie eine Abonnement-Fertig Message.

message

Abgeschlossene Nachricht.

items

Gesammelte Lookup-Artikel.

Rückgabe: Subscription-Instanz.

ProcessSubscriptionOnlineMessage

public Subscription ProcessSubscriptionOnlineMessage(SubscriptionOnlineMessage message, Object[] items)

result = connectorSubscriptionManager.ProcessSubscriptionOnlineMessage(message, items)

Verarbeiten Sie eine Online-Abonnementnachricht.

message

Online-Nachricht.

items

Gesammelte Lookup-Artikel.

Rückgabe: Subscription-Instanz.

Subscribe

public Actions Subscribe(Subscription subscription, bool isAllExtension)

result = connectorSubscriptionManager.Subscribe(subscription, isAllExtension)

Senden Sie eine Abonnementanfrage.

subscription

Zeichnung.

isAllExtension

Gibt die Erweiterung "alle Finanzinstrumente" an.

Rückgabe: Anwendbare Maßnahmen.

TryGetSubscription

public Subscription TryGetSubscription(long id, bool ignoreAll, bool remove, DateTime? time)

result = connectorSubscriptionManager.TryGetSubscription(id, ignoreAll, remove, time)

Versuchen Sie, ein Abonnement nach ID zu erhalten.

id

Subscription ID.

ignoreAll

Ignorieren Sie "alle Finanzinstrumente" -Mapping.

remove

Aus dem Cache entfernen.

time

Optionale Serverzeit.

Rückgabe: Abonnement oder .

UnSubscribe

public Actions UnSubscribe(Subscription subscription)

result = connectorSubscriptionManager.UnSubscribe(subscription)

Senden Sie eine Abmeldeanfrage.

subscription

Zeichnung.

Rückgabe: Anwendbare Maßnahmen.

UnSubscribeAll

public Actions UnSubscribeAll()

result = connectorSubscriptionManager.UnSubscribeAll()

Abonnieren Sie alle aktiven Abonnements.

Rückgabe: Anwendbare Maßnahmen.

UpdateCandles

public IEnumerable<ValueTuple<Subscription, ICandleMessage>> UpdateCandles(CandleMessage message)

result = connectorSubscriptionManager.UpdateCandles(message)

Aktualisieren Sie Kerzen für Abonnements und geben Sie aktualisierte Ergebnisse zurück.

message

Kerzenmeldung.

Rückgabe: Aktualisierte Abonnements mit Kerzen.