IStreamQueueBalancer

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. IStreamQueueBalancer

interface

Namespace: Orleans.Streams

NuGetMarkdown

The stream queue balancer is responsible for load balancing queues across all other related queue balancers. It notifies any listeners (

IStreamQueueBalanceListener

) of changes to the distribution of queues. Method GetMyQueues, SubscribeToQueueDistributionChangeEvents, and UnSubscribeFromQueueDistributionChangeEvents will likely be called in the IStreamQueueBalanceListener's thread so they need to be thread safe

public interface IStreamQueueBalancer

Methods

• GetMyQueues Retrieves the latest queue distribution for this balancer.
• Initialize(IStreamQueueMapper) Initializes this instance.
• Shutdown Shutdown the queue balancer.
• SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener) Subscribes to receive queue distribution change notifications
• UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener) Unsubscribes from receiving queue distribution notifications.