SubscriptionReplayTracker

StockSharp.Messages

社内で再接続を処理するconnectorsのアクティブなサブスクリプションを追跡します。 再接続後、クローンされたサブスクリプションは、 から = null (オンラインのみ、履歴再要求なし) を提供します。

プロパティ

Count
public int Count { get; }
value = subscriptionReplayTracker.Count

現在追跡されたサブスクリプションの数。

メソッド

Clear
public void Clear()
subscriptionReplayTracker.Clear()

追跡されたすべてのサブスクリプションをクリアします。 完全なリセット/切断に電話をかけます。

GetSubscriptionsForReplay
public IEnumerable<ISubscriptionMessage> GetSubscriptionsForReplay()
result = subscriptionReplayTracker.GetSubscriptionsForReplay()

内部再接続後に再生するためのすべてのアクティブなサブスクリプションを取得します。 元のトランザクションIDの下に = null からクローンを返すため、再接続は、アダプタ上のコードに透明にとどまります。外部の購読者は、txId下にデータを受信し続けるため、元々に購読します。

戻り値: サブスクリプションメッセージが再送信されるように修正しました。

Process
public void Process(ISubscriptionMessage message)
subscriptionReplayTracker.Process(message)

サブスクリプションをIsSubscribe@に追跡または追跡します。

message
サブスクリプションメッセージ。
Track
public void Track(ISubscriptionMessage message)
subscriptionReplayTracker.Track(message)

サブスクリプションを追跡します。 アダプターが購読メッセージを受信したときに電話をかけます。

message
サブスクリプションメッセージ(IsSubscribe は真でなければなりません)。
Untrack
public bool Untrack(long originalTransactionId)
result = subscriptionReplayTracker.Untrack(originalTransactionId)

サブスクリプションの追跡を停止します。 アダプターが退会メッセージを受信したときに電話をかけます。

originalTransactionId
サブスクリプションの元のトランザクションIDは削除します。

戻り値: サブスクリプションが見つかった場合、削除されます。