IStreamQueueBalancer Interface

Definition

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
type IStreamQueueBalancer = interface
Public Interface IStreamQueueBalancer
Derived

Methods

GetMyQueues()

Retrieves the latest queue distribution for this balancer.

Initialize(IStreamQueueMapper)

Initializes this instance.

Initialize(String, IStreamQueueMapper, TimeSpan)

Initialize this instance

Shutdown()

Shutdown the queue balancer.

SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener)

Subscribes to receive queue distribution change notifications

UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener)

Unsubscribes from receiving queue distribution notifications.

Applies to