Поделиться через


QueueBalancerBase Класс

Определение

Базовый класс для StreamQueueBalancer

public abstract class QueueBalancerBase : Orleans.Streams.IStreamQueueBalancer
type QueueBalancerBase = class
    interface IStreamQueueBalancer
Public MustInherit Class QueueBalancerBase
Implements IStreamQueueBalancer
Наследование
QueueBalancerBase
Производный
Реализации

Конструкторы

QueueBalancerBase()

Базовый класс для StreamQueueBalancer

QueueBalancerBase(IServiceProvider, ILogger)

Базовый класс для StreamQueueBalancer

Поля

queueBalanceListeners

Коллекция для IStreamQueueBalancerListener

Свойства

Cancellation

Базовый класс для StreamQueueBalancer

Logger

Базовый класс для StreamQueueBalancer

SiloAddress

Базовый класс для StreamQueueBalancer

Методы

GetMyQueues()

Извлекает последнее распределение очередей для этого балансировщика.

Initialize(IStreamQueueMapper)

Инициализирует этот экземпляр.

NotifyListeners()

Базовый класс для StreamQueueBalancer

OnClusterMembershipChange(HashSet<SiloAddress>)

Базовый класс для StreamQueueBalancer

Shutdown()

Базовый класс для StreamQueueBalancer

SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener)

Подписывается на получение уведомлений об изменениях распределения очереди

UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener)

Отмена подписки на получение уведомлений о распределении очередей.

Применяется к