Class AmqpReplyToSinkStage

Connects to an AMQP server upon materialization and sends incoming messages to the server. Each materialized sink will create one connection to the broker. This stage sends messages to the queue named in the replyTo options of the message instead of from settings declared at construction.

Inheritance

Object

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

AmqpReplyToSinkStage

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 AmqpReplyToSinkStage : GraphStageWithMaterializedValue<SinkShape<OutgoingMessage>, Task>, IGraphStageWithMaterializedValue<SinkShape<OutgoingMessage>, Task>, IGraph<SinkShape<OutgoingMessage>, Task>, IGraph<SinkShape<OutgoingMessage>>

Constructors

| Improve this Doc View Source

AmqpReplyToSinkStage(AmqpReplyToSinkSettings)

Declaration

public AmqpReplyToSinkStage(AmqpReplyToSinkSettings settings)

Parameters

Type	Name	Description
AmqpReplyToSinkSettings	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 AmqpReplyToSinkSettings Settings { get; }

Property Value

Type	Description
AmqpReplyToSinkSettings

| 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>