Class QueueSink

A Akka.Streams.Dsl.Sink<TIn, TMat> for the Azure Storage Queue

Inheritance

Object

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<String>, Task>

QueueSink

Implements

Akka.Streams.Stage.IGraphStageWithMaterializedValue<Akka.Streams.SinkShape<String>, Task>

Akka.Streams.IGraph<Akka.Streams.SinkShape<String>, Task>

Akka.Streams.IGraph<Akka.Streams.SinkShape<String>>

Inherited Members

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<System.String>, System.Threading.Tasks.Task>.WithAttributes(Akka.Streams.Attributes)

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<System.String>, System.Threading.Tasks.Task>.CreateLogicAndMaterializedValue(Akka.Streams.Attributes)

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<System.String>, System.Threading.Tasks.Task>.AddAttributes(Akka.Streams.Attributes)

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<System.String>, System.Threading.Tasks.Task>.Named(System.String)

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<System.String>, System.Threading.Tasks.Task>.Async()

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<System.String>, System.Threading.Tasks.Task>.InitialAttributes

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<System.String>, System.Threading.Tasks.Task>.Shape

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<System.String>, System.Threading.Tasks.Task>.Module

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.Streams.Azure.StorageQueue

Assembly: Akka.Streams.Azure.StorageQueue.dll

Syntax

public class QueueSink : GraphStageWithMaterializedValue<SinkShape<string>, Task>, IGraphStageWithMaterializedValue<SinkShape<string>, Task>, IGraph<SinkShape<string>, Task>, IGraph<SinkShape<string>>

Constructors

| Improve this Doc View Source

QueueSink(QueueClient, AddRequestOptions)

Create a new instance of the QueueSink

Declaration

public QueueSink(QueueClient queue, AddRequestOptions options = null)

Parameters

Type	Name	Description
Azure.Storage.Queues.QueueClient	queue	The queue
AddRequestOptions	options	The options for the Azure.Storage.Queues.QueueClient.SendMessageAsync(System.String) call

Properties

| Improve this Doc View Source

In

Declaration

public Inlet<string> In { get; }

Property Value

Type	Description
Akka.Streams.Inlet<String>

| Improve this Doc View Source

InitialAttributes

Declaration

protected override Attributes InitialAttributes { get; }

Property Value

Type	Description
Akka.Streams.Attributes

Overrides

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<System.String>, System.Threading.Tasks.Task>.InitialAttributes

| Improve this Doc View Source

Shape

Declaration

public override SinkShape<string> Shape { get; }

Property Value

Type	Description
Akka.Streams.SinkShape<String>

Overrides

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<System.String>, System.Threading.Tasks.Task>.Shape

Methods

| Improve this Doc View Source

Create(QueueClient, AddRequestOptions)

Creates a Akka.Streams.Dsl.Sink<TIn, TMat> for the Azure Storage Queue

Declaration

public static Sink<string, Task> Create(QueueClient queue, AddRequestOptions options = null)

Parameters

Type	Name	Description
Azure.Storage.Queues.QueueClient	queue	The queue
AddRequestOptions	options	The options for the Azure.Storage.Queues.QueueClient.SendMessageAsync(System.String) call

Returns

Type	Description
Akka.Streams.Dsl.Sink<String, Task>	The Akka.Streams.Dsl.Sink<TIn, TMat> for the Azure Storage Queue

| Improve this Doc View Source

CreateLogicAndMaterializedValue(Attributes)

Declaration

public override ILogicAndMaterializedValue<Task> CreateLogicAndMaterializedValue(Attributes inheritedAttributes)

Parameters

Type	Name	Description
Akka.Streams.Attributes	inheritedAttributes

Returns

Type	Description
Akka.Streams.Stage.ILogicAndMaterializedValue<Task>

Overrides

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<System.String>, System.Threading.Tasks.Task>.CreateLogicAndMaterializedValue(Akka.Streams.Attributes)

Implements

Akka.Streams.Stage.IGraphStageWithMaterializedValue<TShape, TMaterialized>

Akka.Streams.IGraph<TShape, TMaterialized>

Akka.Streams.IGraph<TShape>