SubscriptionReplayTracker

StockSharp.Messages

Verfolgt aktive Abonnements für connectors, die die Reconnection intern handhaben. Nach der Reconnection stellt es geklonte Abonnements mit From = null bereit (nur online, keine erneute Anforderung der Historie).

Eigenschaften

Count

public int Count { get; }

value = subscriptionReplayTracker.Count

Anzahl der aktuell verfolgten Abonnements.

Methoden

Clear

public void Clear()

subscriptionReplayTracker.Clear()

Alle verfolgten Abonnements löschen. Aufrufen Sie bei vollständigem Zurücksetzen/Abtrennen.

GetSubscriptionsForReplay

public IEnumerable<ISubscriptionMessage> GetSubscriptionsForReplay()

result = subscriptionReplayTracker.GetSubscriptionsForReplay()

Gibt Klone mit From = null unter den ursprünglichen Transaktions-IDs zurück, so dass die Reconnect transparent bleibt, um über dem Adapter zu codieren - externe Abonnenten erhalten weiterhin Daten unter txId, mit denen sie ursprünglich abonniert haben.

Rückgabe: Geklonte abonnementnachrichten, die bereit sind, erneut gesendet zu werden.

Process

public void Process(ISubscriptionMessage message)

subscriptionReplayTracker.Process(message)

Verfolgen oder Untracken eines Abonnements basierend auf IsSubscribe.

message: Abonnementnachricht.

Track

public void Track(ISubscriptionMessage message)

subscriptionReplayTracker.Track(message)

Verfolgen Sie ein Abonnement, rufen Sie an, wenn der Adapter eine Abonnementnachricht erhält.

message: Abonnementnachricht (IsSubscribe muss wahr sein).

Untrack

public bool Untrack(long originalTransactionId)

result = subscriptionReplayTracker.Untrack(originalTransactionId)

Stoppen Sie das Tracking eines Abonnements, rufen Sie an, wenn der Adapter eine Abmeldemeldung erhält.

originalTransactionId: Original Transaktions-ID des zu entfernenden Abonnements.

Rückgabe: wenn das Abonnement gefunden und entfernt wurde.