SubscriptionRegistry

SubscriptionRegistry

public SubscriptionRegistry(IStrategyHost host)

subscriptionRegistry = SubscriptionRegistry(host)

订阅跟踪。 管理订阅/ 取消订阅, 暂停/ 重做规则 。

host

战略东道主。

IsRulesSuspended

public bool IsRulesSuspended { get; }

value = subscriptionRegistry.IsRulesSuspended

规则是否目前被暂停 。

Subscriptions

public IEnumerable<Subscription> Subscriptions { get; }

value = subscriptionRegistry.Subscriptions

所有追踪订阅。

CanProcess

public bool CanProcess(Subscription subscription)

result = subscriptionRegistry.CanProcess(subscription)

检查订阅是否跟踪到 。

Reset

public void Reset()

subscriptionRegistry.Reset()

清除所有订阅 。

ResumeRules

public void ResumeRules()

subscriptionRegistry.ResumeRules()

恢复订阅处理。 发送队列订阅 。

Subscribe

public void Subscribe(Subscription subscription, bool isGlobal)

subscriptionRegistry.Subscribe(subscription, isGlobal)

订阅和音轨。 需要时自动指定 TransactionId 。 如果规则被暂停, 则排队等待 。

SuspendRules

public void SuspendRules()

subscriptionRegistry.SuspendRules()

暂停订阅处理(按规则).

TryGetById

public Subscription TryGetById(long transactionId)

result = subscriptionRegistry.TryGetById(transactionId)

尝试通过交易身份查找订阅 。

UnSubscribe

public void UnSubscribe(Subscription subscription)

subscriptionRegistry.UnSubscribe(subscription)

取消订阅。 如果暂停, 尚未发送, 请从队列中删除 。

UnSubscribeAll

public void UnSubscribeAll(bool globalAndLocal)

subscriptionRegistry.UnSubscribeAll(globalAndLocal)

取消订阅履带订阅,并解除其策略处理.

globalAndLocal

包括全球浏览订阅。

SubscriptionRequested

public event Action<Subscription> SubscriptionRequested

subscriptionRegistry.SubscriptionRequested += handler

订阅时启动 connector 。

UnsubscriptionRequested

public event Action<Subscription> UnsubscriptionRequested

subscriptionRegistry.UnsubscriptionRequested += handler

向 connector 发送未订阅时点火 。