SubscriptionRegistry
Отслеживание подписки. Управляет подпиской/отказом от подписки, приостановкой/возобновлением правил.
Конструкторы
public SubscriptionRegistry(IStrategyHost host)
subscriptionRegistry = SubscriptionRegistry(host)
Отслеживание подписки. Управляет подпиской/отказом от подписки, приостановкой/возобновлением правил.
- host
- Ведущий стратегии.
Свойства
public bool IsRulesSuspended { get; }
value = subscriptionRegistry.IsRulesSuspended
Приостановлены ли в настоящее время правила.
public IEnumerable<Subscription> Subscriptions { get; }
value = subscriptionRegistry.Subscriptions
Все отслеживаемые подписки.
Методы
public bool CanProcess(Subscription subscription)
result = subscriptionRegistry.CanProcess(subscription)
Проверьте, отслеживается ли подписка.
public void ResumeRules()
subscriptionRegistry.ResumeRules()
Возобновите обработку подписки. Отправляет подписки в очереди.
public void Subscribe(Subscription subscription, bool isGlobal)
subscriptionRegistry.Subscribe(subscription, isGlobal)
Подписывайтесь и следите. При необходимости автоматически назначает TransactionId. Если правила приостановлены, ставится в очередь на потом.
public void SuspendRules()
subscriptionRegistry.SuspendRules()
Приостановить обработку подписки (для правил).
public Subscription TryGetById(long transactionId)
result = subscriptionRegistry.TryGetById(transactionId)
Попробуйте найти подписку по идентификатору транзакции.
public void UnSubscribe(Subscription subscription)
subscriptionRegistry.UnSubscribe(subscription)
Отписаться. Если сообщение приостановлено и еще не отправлено, просто удалите его из очереди.
public void UnSubscribeAll(bool globalAndLocal)
subscriptionRegistry.UnSubscribeAll(globalAndLocal)
Отписаться от отслеживаемых подписок и удалить их из обработки стратегии.
- globalAndLocal
- для включения подписок на глобальный поиск.
События
public event Action<Subscription> SubscriptionRequested
subscriptionRegistry.SubscriptionRequested += handler
Срабатывает, когда подписку необходимо отправить на адрес connector.
public event Action<Subscription> UnsubscriptionRequested
subscriptionRegistry.UnsubscriptionRequested += handler
Срабатывает, когда необходимо отправить отказ от подписки на адрес connector.