ConnectorSubscriptionManager
StockSharp.Algo
管理订阅及其生命周期.
构造函数
ConnectorSubscriptionManager
public ConnectorSubscriptionManager(ILogReceiver logReceiver, IdGenerator transactionIdGenerator, bool sendUnsubscribeWhenDisconnected)connectorSubscriptionManager = ConnectorSubscriptionManager(logReceiver, transactionIdGenerator, sendUnsubscribeWhenDisconnected)管理订阅及其生命周期.
- logReceiver
- 记录接收器。
- transactionIdGenerator
- 交易ID生成器。
- sendUnsubscribeWhenDisconnected
- 指定是否在断开时发送未订阅请求 。
属性
ConnectionState
public ConnectionStates ConnectionState { get; set; }value = connectorSubscriptionManager.ConnectionState
connectorSubscriptionManager.ConnectionState = value当前连接状态 。
IsRestoreSubscriptionOnNormalReconnect
public bool IsRestoreSubscriptionOnNormalReconnect { get; set; }value = connectorSubscriptionManager.IsRestoreSubscriptionOnNormalReconnect
connectorSubscriptionManager.IsRestoreSubscriptionOnNormalReconnect = value重新连接时恢复订阅 。
SendUnsubscribeWhenDisconnected
public bool SendUnsubscribeWhenDisconnected { get; }value = connectorSubscriptionManager.SendUnsubscribeWhenDisconnected指定是否在断开时发送未订阅请求 。
Subscriptions
public IEnumerable<Subscription> Subscriptions { get; }value = connectorSubscriptionManager.Subscriptions当前订阅快照 。
SubscriptionsOnConnect
public CachedSynchronizedSet<Subscription> SubscriptionsOnConnect { get; }value = connectorSubscriptionManager.SubscriptionsOnConnect连接时发送订阅 。
TransactionIdGenerator
public IdGenerator TransactionIdGenerator { get; set; }value = connectorSubscriptionManager.TransactionIdGenerator
connectorSubscriptionManager.TransactionIdGenerator = value交易ID生成器。
方法
GetSubscribers
public IEnumerable<SecurityId> GetSubscribers(DataType dataType)result = connectorSubscriptionManager.GetSubscribers(dataType)获取对指定数据类型有活跃订阅的金融工具.
- dataType
- 数据类型.
返回值: 具有主动订阅功能的金融工具。
GetSubscriptions
public IEnumerable<Subscription> GetSubscriptions(ISubscriptionIdMessage message)result = connectorSubscriptionManager.GetSubscriptions(message)解析指定信件的订阅 。
- message
- 带有订阅身份的邮件 。
返回值: 订阅.
HandleConnected
public Actions HandleConnected(Subscription[] subscriptions)result = connectorSubscriptionManager.HandleConnected(subscriptions)处理连接事件,并按需要恢复订阅.
- subscriptions
- 默认订阅.
返回值: 将采取的行动。
HandleConnected
public Actions HandleConnected(Func<Subscription, bool> subscriptionFilter)result = connectorSubscriptionManager.HandleConnected(subscriptionFilter)处理连接事件,并按需要恢复订阅.
- subscriptionFilter
- SubscriptionsOnConnect 过滤器 。
返回值: 将采取的行动。
ProcessLookupResponse``1
public IEnumerable<Subscription> ProcessLookupResponse<T>(ISubscriptionIdMessage message, T item)result = connectorSubscriptionManager.ProcessLookupResponse(message, item)处理一个查询回复项目。
- message
- 查取消息 。
- item
- 检查项目 。
返回值: 收到的订阅项目。
ProcessResponse
public Subscription ProcessResponse(SubscriptionResponseMessage response, ISubscriptionMessage originalMsg, bool unexpectedCancelled, Object[] items)result = connectorSubscriptionManager.ProcessResponse(response, originalMsg, unexpectedCancelled, items)处理订阅响应消息 。
- response
- 回应信息.
- originalMsg
- 原始订阅请求.
- unexpectedCancelled
- 显示活动订阅因出错被取消 。
- items
- 收集了检查项目 。
返回值: 订阅实例 。
ProcessSubscriptionFinishedMessage
public Subscription ProcessSubscriptionFinishedMessage(SubscriptionFinishedMessage message, Object[] items)result = connectorSubscriptionManager.ProcessSubscriptionFinishedMessage(message, items)处理一个订阅完成的消息 。
- message
- 完成信件 。
- items
- 收集了检查项目 。
返回值: 订阅实例 。
ProcessSubscriptionOnlineMessage
public Subscription ProcessSubscriptionOnlineMessage(SubscriptionOnlineMessage message, Object[] items)result = connectorSubscriptionManager.ProcessSubscriptionOnlineMessage(message, items)处理订阅在线消息 。
- message
- 网易新闻.
- items
- 收集了检查项目 。
返回值: 订阅实例 。
Subscribe
public Actions Subscribe(Subscription subscription, bool isAllExtension)result = connectorSubscriptionManager.Subscribe(subscription, isAllExtension)发送订阅请求 。
- subscription
- 订阅.
- isAllExtension
- 指"所有金融工具"的扩展.
返回值: 将采取的行动。
TryGetSubscription
public Subscription TryGetSubscription(long id, bool ignoreAll, bool remove, DateTime? time)result = connectorSubscriptionManager.TryGetSubscription(id, ignoreAll, remove, time)试着通过ID订阅。
- id
- 订阅 id.
- ignoreAll
- 忽略"所有金融工具"的映射.
- remove
- 从缓存中移除 。
- time
- 可选服务器时间 。
返回值: 订阅或.
UnSubscribe
public Actions UnSubscribe(Subscription subscription)result = connectorSubscriptionManager.UnSubscribe(subscription)发送未订阅请求 。
- subscription
- 订阅.
返回值: 将采取的行动。
UnSubscribeAll
public Actions UnSubscribeAll()result = connectorSubscriptionManager.UnSubscribeAll()取消订阅所有活动订阅 。
返回值: 将采取的行动。
UpdateCandles
public IEnumerable<ValueTuple<Subscription, ICandleMessage>> UpdateCandles(CandleMessage message)result = connectorSubscriptionManager.UpdateCandles(message)更新订阅的蜡烛并返回更新的结果。
- message
- 烛光信息.
返回值: 以蜡烛更新订阅.