IStreamQueueMapper Methods

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. IStreamQueueMapper
5. Methods

Markdown

The stream queue mapper returns a list of all queues and is also responsible for mapping streams to queues. Implementation must be thread safe.

GetAllQueues

abstract

public abstract IEnumerable<QueueId> GetAllQueues()

Gets all queues.

Returns

All queues.

GetQueueForStream(StreamId)

abstract

public abstract QueueId GetQueueForStream(StreamId streamId)

Gets the queue for the specified stream.

Parameters

streamIdStreamId

The stream identifier.

Returns

The queue responsible for the specified stream.