Edit

Share via

StreamSubscriptionManagerExtensions.AddSubscription Method

  • Reference

Definition

Namespace:
Orleans.Streams.PubSub
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.Streaming v8.2.0
Package:
Microsoft.Orleans.Core v1.5.10
Package:
Microsoft.Orleans.Core v2.4.5
Package:
Microsoft.Orleans.Core v3.6.5

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, IStreamIdentity, String, Guid, String)
AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, IStreamIdentity, String, Int64, String)
AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, IStreamIdentity, String, String, String)
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, IStreamIdentity, String, Guid, String, String)
AddSubscription<TGrainInterface>(IStreamSubscriptionManager, IGrainFactory, IStreamIdentity, String, Int64, String, String)

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.

Applies to

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.

Applies to

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.

Applies to

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.

Applies to

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

Source:
StreamSubscriptionManagerExtensions.cs
public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Streams.IStreamIdentity streamId, string streamProviderName, Guid primaryKey, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithGuidKey;
static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Streams.IStreamIdentity * 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 IStreamIdentity, streamProviderName As String, primaryKey As Guid, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

Type Parameters

TGrainInterface

Parameters

manager
IStreamSubscriptionManager
grainFactory
IGrainFactory
streamId
IStreamIdentity
streamProviderName
String
primaryKey
Guid
grainClassNamePrefix
String

Returns

Task<StreamSubscription>

Applies to

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

Source:
StreamSubscriptionManagerExtensions.cs
public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Streams.IStreamIdentity streamId, string streamProviderName, long primaryKey, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithIntegerKey;
static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Streams.IStreamIdentity * 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 IStreamIdentity, streamProviderName As String, primaryKey As Long, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

Type Parameters

TGrainInterface

Parameters

manager
IStreamSubscriptionManager
grainFactory
IGrainFactory
streamId
IStreamIdentity
streamProviderName
String
primaryKey
Int64
grainClassNamePrefix
String

Returns

Task<StreamSubscription>

Applies to

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

Source:
StreamSubscriptionManagerExtensions.cs
public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Streams.IStreamIdentity streamId, string streamProviderName, string primaryKey, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithStringKey;
static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Streams.IStreamIdentity * 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 IStreamIdentity, streamProviderName As String, primaryKey As String, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

Type Parameters

TGrainInterface

Parameters

manager
IStreamSubscriptionManager
grainFactory
IGrainFactory
streamId
IStreamIdentity
streamProviderName
String
primaryKey
String
grainClassNamePrefix
String

Returns

Task<StreamSubscription>

Applies to

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.

Applies to

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.

Applies to

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

Source:
StreamSubscriptionManagerExtensions.cs
public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Streams.IStreamIdentity streamId, string streamProviderName, Guid primaryKey, string keyExtension, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithGuidCompoundKey;
static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Streams.IStreamIdentity * 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 IStreamIdentity, streamProviderName As String, primaryKey As Guid, keyExtension As String, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

Type Parameters

TGrainInterface

Parameters

manager
IStreamSubscriptionManager
grainFactory
IGrainFactory
streamId
IStreamIdentity
streamProviderName
String
primaryKey
Guid
keyExtension
String
grainClassNamePrefix
String

Returns

Task<StreamSubscription>

Applies to

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

Source:
StreamSubscriptionManagerExtensions.cs
public static System.Threading.Tasks.Task<Orleans.Streams.Core.StreamSubscription> AddSubscription<TGrainInterface> (this Orleans.Streams.Core.IStreamSubscriptionManager manager, Orleans.IGrainFactory grainFactory, Orleans.Streams.IStreamIdentity streamId, string streamProviderName, long primaryKey, string keyExtension, string grainClassNamePrefix = default) where TGrainInterface : Orleans.IGrainWithIntegerCompoundKey;
static member AddSubscription : Orleans.Streams.Core.IStreamSubscriptionManager * Orleans.IGrainFactory * Orleans.Streams.IStreamIdentity * 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 IStreamIdentity, streamProviderName As String, primaryKey As Long, keyExtension As String, Optional grainClassNamePrefix As String = Nothing) As Task(Of StreamSubscription)

Type Parameters

TGrainInterface

Parameters

manager
IStreamSubscriptionManager
grainFactory
IGrainFactory
streamId
IStreamIdentity
streamProviderName
String
primaryKey
Int64
keyExtension
String
grainClassNamePrefix
String

Returns

Task<StreamSubscription>

Applies to