SubscriptionReplayTracker

StockSharp.Messages

跟踪处理内部重联的 connectors 活动订阅。重联后,提供克隆订阅,使用From = 无效(仅在线,没有历史重接请求) 。

属性

Count

public int Count { get; }

value = subscriptionReplayTracker.Count

目前跟踪订阅次数。

Clear

public void Clear()

subscriptionReplayTracker.Clear()

清除所有履带订阅。呼叫全部重置/ 断开。

public IEnumerable<ISubscriptionMessage> GetSubscriptionsForReplay()

result = subscriptionReplayTracker.GetSubscriptionsForReplay()

获取所有在内部重接后进行重播的激活订阅。返回复制件在原始交易ID下为无效, 重接时会保持透明到适配器上方的代码 —— 外部订阅者会继续接收他们原先订阅的txId的数据。

返回值: 已准备好重新发送的订阅信息。

Process

public void Process(ISubscriptionMessage message)

subscriptionReplayTracker.Process(message)

基于 IsSubscribe 的订阅。

Track

public void Track(ISubscriptionMessage message)

subscriptionReplayTracker.Track(message)

跟踪订阅。适配器收到订阅消息时打电话。

message: 订阅消息(%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%

Untrack

public bool Untrack(long originalTransactionId)

result = subscriptionReplayTracker.Untrack(originalTransactionId)

停止跟踪订阅。适配器收到未订阅信件时, 立即呼叫。

返回值: 如果发现并删除了订阅。