Bagikan melalui


QueueBalancerBase Kelas

Definisi

Kelas dasar untuk StreamQueueBalancer

public abstract class QueueBalancerBase : Orleans.Streams.IStreamQueueBalancer
type QueueBalancerBase = class
    interface IStreamQueueBalancer
Public MustInherit Class QueueBalancerBase
Implements IStreamQueueBalancer
Warisan
QueueBalancerBase
Turunan
Penerapan

Konstruktor

QueueBalancerBase()

Kelas dasar untuk StreamQueueBalancer

QueueBalancerBase(IServiceProvider, ILogger)

Kelas dasar untuk StreamQueueBalancer

Bidang

queueBalanceListeners

Koleksi untuk IStreamQueueBalancerListener-nya

Properti

Cancellation

Kelas dasar untuk StreamQueueBalancer

Logger

Kelas dasar untuk StreamQueueBalancer

SiloAddress

Kelas dasar untuk StreamQueueBalancer

Metode

GetMyQueues()

Mengambil distribusi antrean terbaru untuk penyeimbang ini.

Initialize(IStreamQueueMapper)

Menginisialisasi instans ini.

NotifyListeners()

Kelas dasar untuk StreamQueueBalancer

OnClusterMembershipChange(HashSet<SiloAddress>)

Kelas dasar untuk StreamQueueBalancer

Shutdown()

Kelas dasar untuk StreamQueueBalancer

SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener)

Berlangganan untuk menerima pemberitahuan perubahan distribusi antrean

UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener)

Berhenti berlangganan menerima pemberitahuan distribusi antrean.

Berlaku untuk