SQSAdapterFactory Class

Reference

Definition

Namespace:: OrleansAWSUtils.Streams

Assembly:: OrleansAWSUtils.dll

Assembly:: Orleans.Streaming.SQS.dll

Package:: Microsoft.Orleans.OrleansAWSUtils v1.5.10

Package:: Microsoft.Orleans.Streaming.SQS v2.4.5

Package:: Microsoft.Orleans.Streaming.SQS v3.6.5

Package:: Microsoft.Orleans.Streaming.SQS v7.2.5

Package:: Microsoft.Orleans.Streaming.SQS v8.0.0

Package:: Microsoft.Orleans.Streaming.SQS v8.1.0

Package:: Microsoft.Orleans.Streaming.SQS v8.2.0

Source:: SQSAdapterFactory.cs

Source:: SQSAdapterFactory.cs

Source:: SQSAdapterFactory.cs

Source:: SQSAdapterFactory.cs

Source:: SQSAdapterFactory.cs

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

Factory class for Azure Queue based stream provider.

public class SQSAdapterFactory : Orleans.Streams.IQueueAdapterFactory

type SQSAdapterFactory = class
    interface IQueueAdapterFactory

Public Class SQSAdapterFactory
Implements IQueueAdapterFactory

Inheritance: Object
SQSAdapterFactory

Implements: IQueueAdapterFactory

Constructors

SQSAdapterFactory()
SQSAdapterFactory(String, SqsOptions, HashRingStreamQueueMapperOptions, SimpleQueueCacheOptions, IOptions<ClusterOptions>, Serializer, ILoggerFactory)
SQSAdapterFactory(String, SqsOptions, HashRingStreamQueueMapperOptions, SimpleQueueCacheOptions, IServiceProvider, IOptions<ClusterOptions>, SerializationManager, ILoggerFactory)

Fields

DataConnectionStringPropertyName	"DataConnectionString".
DeploymentIdPropertyName	"DeploymentId".
NumQueuesDefaultValue	Default number of Azure Queue used in this stream provider.

Properties

StreamFailureHandlerFactory

Application level failure handler override.

Methods

Create(IServiceProvider, String)
CreateAdapter()	Creates the Azure Queue based adapter.
GetDeliveryFailureHandler(QueueId)	Creates a delivery failure handler for the specified queue.
GetQueueAdapterCache()	Creates the adapter cache.
GetStreamQueueMapper()	Creates the factory stream queue mapper.
Init()	Init the factory.
Init(IProviderConfiguration, String, Logger, IServiceProvider)	Init the factory.

Applies to

Share via