HashRingBasedStreamQueueMapper Constructors

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. HashRingBasedStreamQueueMapper
5. Constructors

Markdown

A IConsistentRingStreamQueueMapper and hence IStreamQueueMapper which balances queues by mapping them onto a hash ring consisting of silos.

HashRingBasedStreamQueueMapper(HashRingStreamQueueMapperOptions, string)

View source

public HashRingBasedStreamQueueMapper(HashRingStreamQueueMapperOptions options, string queueNamePrefix)

Initializes a new instance of the HashRingBasedStreamQueueMapper class.

Parameters

optionsHashRingStreamQueueMapperOptions

The options.

queueNamePrefixstring

The queue name prefix.