Class AmqpSinkStage

Connects to an AMQP server upon materialization and sends incoming messages to the server. Each materialized sink will create one connection to the broker.

Inheritance

Object

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

AmqpSinkStage

Implements

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

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

Akka.Streams.IGraph<Akka.Streams.SinkShape<OutgoingMessage>>

Inherited Members

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

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

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

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

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

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<Akka.Streams.Amqp.RabbitMq.OutgoingMessage>, System.Threading.Tasks.Task>.InitialAttributes

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<Akka.Streams.Amqp.RabbitMq.OutgoingMessage>, System.Threading.Tasks.Task>.Shape

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<Akka.Streams.Amqp.RabbitMq.OutgoingMessage>, System.Threading.Tasks.Task>.Module

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Namespace: Akka.Streams.Amqp.RabbitMq

Assembly: Akka.Streams.Amqp.RabbitMq.dll

Syntax

public sealed class AmqpSinkStage : GraphStageWithMaterializedValue<SinkShape<OutgoingMessage>, Task>, IGraphStageWithMaterializedValue<SinkShape<OutgoingMessage>, Task>, IGraph<SinkShape<OutgoingMessage>, Task>, IGraph<SinkShape<OutgoingMessage>>

Constructors

| Improve this Doc View Source

AmqpSinkStage(AmqpSinkSettings)

Declaration

public AmqpSinkStage(AmqpSinkSettings settings)

Parameters

Type	Name	Description
AmqpSinkSettings	settings

Fields

| Improve this Doc View Source

DefaultAttributes

Declaration

public static readonly Attributes DefaultAttributes

Field Value

Type	Description
Akka.Streams.Attributes

| Improve this Doc View Source

In

Declaration

public readonly Inlet<OutgoingMessage> In

Field Value

Type	Description
Akka.Streams.Inlet<OutgoingMessage>

Properties

| 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<Akka.Streams.Amqp.RabbitMq.OutgoingMessage>, System.Threading.Tasks.Task>.InitialAttributes

| Improve this Doc View Source

Settings

Declaration

public AmqpSinkSettings Settings { get; }

Property Value

Type	Description
AmqpSinkSettings

| Improve this Doc View Source

Shape

Declaration

public override SinkShape<OutgoingMessage> Shape { get; }

Property Value

Type	Description
Akka.Streams.SinkShape<OutgoingMessage>

Overrides

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SinkShape<Akka.Streams.Amqp.RabbitMq.OutgoingMessage>, System.Threading.Tasks.Task>.Shape

Methods

| 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

| Improve this Doc View Source

ToString()

Declaration

public override string ToString()

Returns

Type	Description
String

Overrides

Object.ToString()

Implements

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

Akka.Streams.IGraph<TShape, TMaterialized>

Akka.Streams.IGraph<TShape>