AzureQueueStreamProvider Class

Definition

Namespace:

Orleans.Providers.Streams.AzureQueue

Assembly:

OrleansAzureUtils.dll

Package:

Microsoft.Orleans.OrleansAzureUtils v1.5.10

Caution

This version is maintained for compatability purposes. New services should use AzureQueueStreamProviderV2 as it supports external serializers.

Persistent stream provider that uses azure queue for persistence WARNING: This version is maintained for compatability purposes. New services should use AzureQueueStreamProviderV2 as it supports external serializers.

[System.Obsolete("This version is maintained for compatability purposes. New services should use AzureQueueStreamProviderV2 as it supports external serializers.")]
public class AzureQueueStreamProvider : Orleans.Providers.Streams.Common.PersistentStreamProvider<Orleans.Providers.Streams.AzureQueue.AzureQueueAdapterFactory<Orleans.Providers.Streams.AzureQueue.AzureQueueDataAdapterV1>>

[<System.Obsolete("This version is maintained for compatability purposes. New services should use AzureQueueStreamProviderV2 as it supports external serializers.")>]
type AzureQueueStreamProvider = class
    inherit PersistentStreamProvider<AzureQueueAdapterFactory<AzureQueueDataAdapterV1>>

Public Class AzureQueueStreamProvider
Inherits PersistentStreamProvider(Of AzureQueueAdapterFactory(Of AzureQueueDataAdapterV1))

Inheritance

Object

PersistentStreamProvider<AzureQueueAdapterFactory<AzureQueueDataAdapterV1>>

AzureQueueStreamProvider

Attributes

ObsoleteAttribute

Constructors

AzureQueueStreamProvider()

Properties

IsRewindable	(Inherited from PersistentStreamProvider<TAdapterFactory>)
Name	(Inherited from PersistentStreamProvider<TAdapterFactory>)

Methods

Close()	(Inherited from PersistentStreamProvider<TAdapterFactory>)
ExecuteCommand(Int32, Object)	(Inherited from PersistentStreamProvider<TAdapterFactory>)
GetStream<T>(Guid, String)	(Inherited from PersistentStreamProvider<TAdapterFactory>)
GetStreamSubscriptionManager()	(Inherited from PersistentStreamProvider<TAdapterFactory>)
Init(String, IProviderRuntime, IProviderConfiguration)	(Inherited from PersistentStreamProvider<TAdapterFactory>)
Start()	(Inherited from PersistentStreamProvider<TAdapterFactory>)

Extension Methods

TryGetStreamSubscrptionManager(IStreamProvider, IStreamSubscriptionManager)