Edytuj

Udostępnij za pośrednictwem

EventHubQueueMapper Class

  • Reference

Definition

Namespace:
Orleans.ServiceBus.Providers
Assembly:
OrleansServiceBus.dll
Assembly:
Orleans.Streaming.EventHubs.dll
Package:
Microsoft.Orleans.OrleansServiceBus v1.5.10
Package:
Microsoft.Orleans.OrleansServiceBus v2.4.5
Package:
Microsoft.Orleans.OrleansServiceBus v3.6.5
Source:
EventHubQueueMapper.cs

Queue mapper that tracks which EventHub partition was mapped to which 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
Inheritance
Object
HashRingBasedStreamQueueMapper
EventHubQueueMapper
Implements
IEventHubQueueMapper IStreamQueueMapper

Constructors

EventHubQueueMapper(String[], String)

Queue mapper that tracks which EventHub partition was mapped to which queueId

Methods

GetAllQueues()

Gets all queues.

(Inherited from HashRingBasedStreamQueueMapper)
GetQueueForStream(Guid, String) (Inherited from HashRingBasedStreamQueueMapper)
GetQueueForStream(StreamId)

Gets the queue for the specified stream.

(Inherited from HashRingBasedStreamQueueMapper)
GetQueuesForRange(IRingRange)

Gets the queues which map to the specified range.

(Inherited from HashRingBasedStreamQueueMapper)
QueueToPartition(QueueId)

Gets the EventHub partition by QueueId
ToString() (Inherited from HashRingBasedStreamQueueMapper)

Applies to