StreamSubscriptionManagerExtensions.AddSubscription Method

Definition

Namespace:

Orleans.Streams.PubSub

Assembly:

Orleans.Streaming.dll

Package:

Microsoft.Orleans.Streaming v8.1.0

Overloads

AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, GrainId)	Subscribes the specified grain to the specified stream.
AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Guid, String)	Subscribes the specified grain to the specified stream.
AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Int64, String)	Subscribes the specified grain to the specified stream.
AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, String, String)	Subscribes the specified grain to the specified stream.
AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Guid, String, String)	Subscribes the specified grain to the specified stream.
AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Int64, String, String)	Subscribes the specified grain to the specified stream.

AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, GrainId)

Subscribes the specified grain to the specified stream.

public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Runtime.StreamId streamId, string streamProviderName, Orleans.Runtime.GrainId grainId) where TGrainInterface : Orleans.IGrainWithGuidKey;

static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Runtime.StreamId * string * Orleans.Runtime.GrainId -> System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> (requires 'GrainInterface :> Orleans.IGrainWithGuidKey)

<Extension()>
Public Function AddSubscription(Of TGrainInterface As IGrainWithGuidKey) (manager As IStreamSubscriptionManager, grainFactory As IGrainFactory, streamId As StreamId, streamProviderName As String, grainId As GrainId) As Task(Of StreamSubscription)

Type Parameters

TGrainInterface

The grain interface type.

Parameters

manager

IStreamSubscriptionManager

The manager.

grainFactory

IGrainFactory

The grain factory.

streamId

StreamId

The stream identifier.

streamProviderName

String

Name of the stream provider.

grainId

GrainId

The grain to subscribe.

Returns

Task<StreamSubscription>

The newly added subscription.

AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Guid, String)

Subscribes the specified grain to the specified stream.

public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Runtime.StreamId streamId, string streamProviderName, Guid primaryKey, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithGuidKey;

static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Runtime.StreamId * string * Guid * string -> System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> (requires 'GrainInterface :> Orleans.IGrainWithGuidKey)

<Extension()>
Public Function AddSubscription(Of TGrainInterface As IGrainWithGuidKey) (manager As IStreamSubscriptionManager, grainFactory As IGrainFactory, streamId As StreamId, streamProviderName As String, primaryKey As Guid, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

Type Parameters

TGrainInterface

An interface which the grain is the primary implementation of.

Parameters

manager

IStreamSubscriptionManager

The manager.

grainFactory

IGrainFactory

The grain factory.

streamId

StreamId

The stream identifier.

streamProviderName

String

Name of the stream provider.

primaryKey

Guid

The grain's primary key.

grainClassNamePrefix

String

The grain class name prefix.

Returns

Task<StreamSubscription>

The newly added subscription.

AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Int64, String)

Subscribes the specified grain to the specified stream.

public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Runtime.StreamId streamId, string streamProviderName, long primaryKey, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithIntegerKey;

static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Runtime.StreamId * string * int64 * string -> System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> (requires 'GrainInterface :> Orleans.IGrainWithIntegerKey)

<Extension()>
Public Function AddSubscription(Of TGrainInterface As IGrainWithIntegerKey) (manager As IStreamSubscriptionManager, grainFactory As IGrainFactory, streamId As StreamId, streamProviderName As String, primaryKey As Long, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

Type Parameters

TGrainInterface

An interface which the grain is the primary implementation of.

Parameters

manager

IStreamSubscriptionManager

The manager.

grainFactory

IGrainFactory

The grain factory.

streamId

StreamId

The stream identifier.

streamProviderName

String

Name of the stream provider.

primaryKey

Int64

The grain's primary key.

grainClassNamePrefix

String

The grain class name prefix.

Returns

Task<StreamSubscription>

The newly added subscription.

AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, String, String)

Subscribes the specified grain to the specified stream.

public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Runtime.StreamId streamId, string streamProviderName, string primaryKey, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithStringKey;

static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Runtime.StreamId * string * string * string -> System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> (requires 'GrainInterface :> Orleans.IGrainWithStringKey)

<Extension()>
Public Function AddSubscription(Of TGrainInterface As IGrainWithStringKey) (manager As IStreamSubscriptionManager, grainFactory As IGrainFactory, streamId As StreamId, streamProviderName As String, primaryKey As String, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

Type Parameters

TGrainInterface

An interface which the grain is the primary implementation of.

Parameters

manager

IStreamSubscriptionManager

The manager.

grainFactory

IGrainFactory

The grain factory.

streamId

StreamId

The stream identifier.

streamProviderName

String

Name of the stream provider.

primaryKey

String

The grain's primary key.

grainClassNamePrefix

String

The grain class name prefix.

Returns

Task<StreamSubscription>

The newly added subscription.

AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Guid, String, String)

Subscribes the specified grain to the specified stream.

public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Runtime.StreamId streamId, string streamProviderName, Guid primaryKey, string keyExtension, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithGuidCompoundKey;

static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Runtime.StreamId * string * Guid * string * string -> System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> (requires 'GrainInterface :> Orleans.IGrainWithGuidCompoundKey)

<Extension()>
Public Function AddSubscription(Of TGrainInterface As IGrainWithGuidCompoundKey) (manager As IStreamSubscriptionManager, grainFactory As IGrainFactory, streamId As StreamId, streamProviderName As String, primaryKey As Guid, keyExtension As String, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

Type Parameters

TGrainInterface

An interface which the grain is the primary implementation of.

Parameters

manager

IStreamSubscriptionManager

The manager.

grainFactory

IGrainFactory

The grain factory.

streamId

StreamId

The stream identifier.

streamProviderName

String

Name of the stream provider.

primaryKey

Guid

The grain's primary key.

keyExtension

String

The grain's key extension.

grainClassNamePrefix

String

The grain class name prefix.

Returns

Task<StreamSubscription>

The newly added subscription.

AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, StreamId, String, Int64, String, String)

Subscribes the specified grain to the specified stream.

public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Runtime.StreamId streamId, string streamProviderName, long primaryKey, string keyExtension, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithIntegerCompoundKey;

static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Runtime.StreamId * string * int64 * string * string -> System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> (requires 'GrainInterface :> Orleans.IGrainWithIntegerCompoundKey)

<Extension()>
Public Function AddSubscription(Of TGrainInterface As IGrainWithIntegerCompoundKey) (manager As IStreamSubscriptionManager, grainFactory As IGrainFactory, streamId As StreamId, streamProviderName As String, primaryKey As Long, keyExtension As String, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

Type Parameters

TGrainInterface

An interface which the grain is the primary implementation of.

Parameters

manager

IStreamSubscriptionManager

The manager.

grainFactory

IGrainFactory

The grain factory.

streamId

StreamId

The stream identifier.

streamProviderName

String

Name of the stream provider.

primaryKey

Int64

The grain's primary key.

keyExtension

String

The grain's key extension.

grainClassNamePrefix

String

The grain class name prefix.

Returns

Task<StreamSubscription>

The newly added subscription.