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


IStreamQueueBalancer Интерфейс

Определение

Подсистема балансировки потоковой очереди отвечает за балансировку нагрузки очередей во всех других связанных подсистемах балансировки очередей. Он уведомляет всех прослушивателей (IStreamQueueBalanceListener) об изменениях в распределении очередей. Методы GetMyQueues, SubscribeToQueueDistributionChangeEvents и UnSubscribeFromQueueDistributionChangeEvents, скорее всего, будут вызываться в потоке IStreamQueueBalanceListener, чтобы они были потокобезопасны

public interface IStreamQueueBalancer
type IStreamQueueBalancer = interface
Public Interface IStreamQueueBalancer
Производный

Методы

Имя Описание
GetMyQueues()

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

Initialize(IStreamQueueMapper)

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

Initialize(String, IStreamQueueMapper, TimeSpan)

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

Shutdown()

Завершите работу балансировщика очередей.

SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener)

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

UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener)

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

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