Skip to content

HashRingBasedStreamQueueMapper.GetQueueForStream(StreamId)

GetQueueForStream(StreamId)

View source
public QueueId GetQueueForStream(StreamId streamId)
Gets the queue for the specified stream.

Parameters

streamIdStreamId
The stream identifier.

Returns

The queue responsible for the specified stream.