QueueBalancerBase

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

class

Namespace: Orleans.Streams

NuGetSourceMarkdown

Base class for StreamQueueBalancer

public abstract class QueueBalancerBase : 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.