Поделиться через

EventHubQueueMapper Класс

  • Ссылка

Определение

Пространство имен:
Orleans.ServiceBus.Providers
Сборка:
OrleansServiceBus.dll
Сборка:
Orleans.Streaming.EventHubs.dll
Пакет:
Microsoft.Orleans.OrleansServiceBus v1.5.10
Пакет:
Microsoft.Orleans.OrleansServiceBus v2.4.5
Пакет:
Microsoft.Orleans.OrleansServiceBus v3.6.5
Исходный код:
EventHubQueueMapper.cs

Модуль сопоставления очередей, который отслеживает, какой раздел EventHub был сопоставлен с тем, с каким queueId

public class EventHubQueueMapper : Orleans.Streams.HashRingBasedStreamQueueMapper, Orleans.ServiceBus.Providers.IEventHubQueueMapper
type EventHubQueueMapper = class
    inherit HashRingBasedStreamQueueMapper
    interface IEventHubQueueMapper
    interface IStreamQueueMapper
Public Class EventHubQueueMapper
Inherits HashRingBasedStreamQueueMapper
Implements IEventHubQueueMapper
Наследование
Object
HashRingBasedStreamQueueMapper
EventHubQueueMapper
Реализации
IEventHubQueueMapper IStreamQueueMapper

Конструкторы

EventHubQueueMapper(String[], String)

Модуль сопоставления очередей, который отслеживает, какой раздел EventHub был сопоставлен с тем, с каким queueId

Методы

GetAllQueues()

Возвращает все очереди.

(Унаследовано от HashRingBasedStreamQueueMapper)
GetQueueForStream(Guid, String)

Модуль сопоставления очередей, который отслеживает, какой раздел EventHub был сопоставлен с тем, с каким queueId

(Унаследовано от HashRingBasedStreamQueueMapper)
GetQueueForStream(StreamId)

Возвращает очередь для указанного потока.

(Унаследовано от HashRingBasedStreamQueueMapper)
GetQueuesForRange(IRingRange)

Возвращает очереди, которые сопоставляются с указанным диапазоном.

(Унаследовано от HashRingBasedStreamQueueMapper)
QueueToPartition(QueueId)

Возвращает раздел EventHub по QueueId.
ToString()

Модуль сопоставления очередей, который отслеживает, какой раздел EventHub был сопоставлен с тем, с каким queueId

(Унаследовано от HashRingBasedStreamQueueMapper)

Применяется к