Edit

Share via

HashRingBasedStreamQueueMapper.GetQueueForStream Method

  • Reference

Definition

Namespace:
Orleans.Streams
Assembly:
Orleans.Streaming.dll
Assembly:
Orleans.dll
Assembly:
Orleans.Core.dll
Package:
Microsoft.Orleans.Streaming v7.2.5
Package:
Microsoft.Orleans.Streaming v8.0.0
Package:
Microsoft.Orleans.Streaming v8.1.0
Package:
Microsoft.Orleans.Core v1.5.10
Package:
Microsoft.Orleans.Core v2.4.5
Package:
Microsoft.Orleans.Core v3.6.5

Overloads

GetQueueForStream(StreamId)

Gets the queue for the specified stream.
GetQueueForStream(Guid, String)

GetQueueForStream(StreamId)

Gets the queue for the specified stream.

public Orleans.Streams.QueueId GetQueueForStream (Orleans.Runtime.StreamId streamId);
abstract member GetQueueForStream : Orleans.Runtime.StreamId -> Orleans.Streams.QueueId
override this.GetQueueForStream : Orleans.Runtime.StreamId -> Orleans.Streams.QueueId
Public Function GetQueueForStream (streamId As StreamId) As QueueId

Parameters

streamId
StreamId

The stream identifier.

Returns

QueueId

The queue responsible for the specified stream.

Implements

GetQueueForStream(StreamId)

Applies to

GetQueueForStream(Guid, String)

Source:
HashRingBasedStreamQueueMapper.cs
public Orleans.Streams.QueueId GetQueueForStream (Guid streamGuid, string streamNamespace);
abstract member GetQueueForStream : Guid * string -> Orleans.Streams.QueueId
override this.GetQueueForStream : Guid * string -> Orleans.Streams.QueueId
Public Function GetQueueForStream (streamGuid As Guid, streamNamespace As String) As QueueId

Parameters

streamGuid
Guid
streamNamespace
String

Returns

QueueId

Implements

GetQueueForStream(Guid, String)

Applies to