GetMyQueues
abstract
public abstract IEnumerable<QueueId> GetMyQueues() Retrieves the latest queue distribution for this balancer.
Returns
Queue allocated to this balancer.
QueueBalancerBase Methods
Base class for StreamQueueBalancer
Initialize(IStreamQueueMapper)
virtual
public virtual Task Initialize(IStreamQueueMapper queueMapper) Initializes this instance.
Parameters
queueMapperIStreamQueueMapper- The queue mapper.
Returns
A
System.Threading.Tasks.Task representing the operation.NotifyListeners
protected Task NotifyListeners() Notifies subscribers that the queue distribution has changed.
Returns
A task which represents the notification operation.
OnClusterMembershipChange(HashSet<SiloAddress>)
abstract
protected abstract void OnClusterMembershipChange(HashSet<SiloAddress> activeSilos) Handles a change to the set of active silos.
Parameters
activeSilosHashSet<SiloAddress>- The addresses of the active silos.
Shutdown
virtual
public virtual Task Shutdown() Shutdown the queue balancer.
Returns
A
System.Threading.Tasks.Task representing the operation.SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener)
public bool SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener observer) Subscribes to receive queue distribution change notifications
Parameters
observerIStreamQueueBalanceListener- An observer interface to receive queue distribution change notifications.
Returns
A value indicating whether subscription succeeded or not.
UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener)
public bool UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener observer) Unsubscribes from receiving queue distribution notifications.
Parameters
observerIStreamQueueBalanceListener- An observer interface to receive queue distribution change notifications.
Returns
A value indicating whether teh unsubscription succeeded or not