Class AmqpFlowStage<TPassThrough>

This stage materializes to a Task

Inheritance

Object

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.FlowShape<System.ValueTuple<OutgoingMessage, TPassThrough>, TPassThrough>, Task>

AmqpFlowStage<TPassThrough>

Implements

Akka.Streams.Stage.IGraphStageWithMaterializedValue<Akka.Streams.FlowShape<System.ValueTuple<OutgoingMessage, TPassThrough>, TPassThrough>, Task>

Akka.Streams.IGraph<Akka.Streams.FlowShape<System.ValueTuple<OutgoingMessage, TPassThrough>, TPassThrough>, Task>

Akka.Streams.IGraph<Akka.Streams.FlowShape<System.ValueTuple<OutgoingMessage, TPassThrough>, TPassThrough>>

Inherited Members

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

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

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

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

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

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

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

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.FlowShape<System.ValueTuple<Akka.Streams.Amqp.RabbitMq.OutgoingMessage, TPassThrough>, TPassThrough>, 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 class AmqpFlowStage<TPassThrough> : GraphStageWithMaterializedValue<FlowShape<(OutgoingMessage, TPassThrough), TPassThrough>, Task>, IGraphStageWithMaterializedValue<FlowShape<(OutgoingMessage, TPassThrough), TPassThrough>, Task>, IGraph<FlowShape<(OutgoingMessage, TPassThrough), TPassThrough>, Task>, IGraph<FlowShape<(OutgoingMessage, TPassThrough), TPassThrough>>

Type Parameters

Name	Description
TPassThrough

Constructors

AmqpFlowStage(AmqpSinkSettings)

Declaration

public AmqpFlowStage(AmqpSinkSettings settings)

Parameters

Type	Name	Description
AmqpSinkSettings	settings

Fields

DefaultAttributes

Declaration

public static readonly Attributes DefaultAttributes

Field Value

Type	Description
Akka.Streams.Attributes

In

Declaration

public readonly Inlet<(OutgoingMessage, TPassThrough)> In

Field Value

Type	Description
Akka.Streams.Inlet<System.ValueTuple<OutgoingMessage, TPassThrough>>

Out

Declaration

public readonly Outlet<TPassThrough> Out

Field Value

Type	Description
Akka.Streams.Outlet<TPassThrough>

Properties

InitialAttributes

Declaration

protected override Attributes InitialAttributes { get; }

Property Value

Type	Description
Akka.Streams.Attributes

Overrides

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

Settings

Declaration

public AmqpSinkSettings Settings { get; }

Property Value

Type	Description
AmqpSinkSettings

Shape

Declaration

public override FlowShape<(OutgoingMessage, TPassThrough), TPassThrough> Shape { get; }

Property Value

Type	Description
Akka.Streams.FlowShape<System.ValueTuple<OutgoingMessage, TPassThrough>, TPassThrough>

Overrides

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

Methods

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.FlowShape<System.ValueTuple<Akka.Streams.Amqp.RabbitMq.OutgoingMessage, TPassThrough>, TPassThrough>, System.Threading.Tasks.Task>.CreateLogicAndMaterializedValue(Akka.Streams.Attributes)

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>