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.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