Class AmqpRpcFlowStage

This stage materializes to a Task<TResult>, which is the name of the private exclusive queue used for RPC communication

Inheritance

Object

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.FlowShape<OutgoingMessage, CommittableIncomingMessage>, Task<String>>

AmqpRpcFlowStage

Implements

Akka.Streams.Stage.IGraphStageWithMaterializedValue<Akka.Streams.FlowShape<OutgoingMessage, CommittableIncomingMessage>, Task<String>>

Akka.Streams.IGraph<Akka.Streams.FlowShape<OutgoingMessage, CommittableIncomingMessage>, Task<String>>

Akka.Streams.IGraph<Akka.Streams.FlowShape<OutgoingMessage, CommittableIncomingMessage>>

Inherited Members

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

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

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

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

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.FlowShape<Akka.Streams.Amqp.RabbitMq.OutgoingMessage, Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, System.Threading.Tasks.Task<System.String>>.Async()

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.FlowShape<Akka.Streams.Amqp.RabbitMq.OutgoingMessage, Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, System.Threading.Tasks.Task<System.String>>.InitialAttributes

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.FlowShape<Akka.Streams.Amqp.RabbitMq.OutgoingMessage, Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, System.Threading.Tasks.Task<System.String>>.Shape

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.FlowShape<Akka.Streams.Amqp.RabbitMq.OutgoingMessage, Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, System.Threading.Tasks.Task<System.String>>.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 AmqpRpcFlowStage : GraphStageWithMaterializedValue<FlowShape<OutgoingMessage, CommittableIncomingMessage>, Task<string>>, IGraphStageWithMaterializedValue<FlowShape<OutgoingMessage, CommittableIncomingMessage>, Task<string>>, IGraph<FlowShape<OutgoingMessage, CommittableIncomingMessage>, Task<string>>, IGraph<FlowShape<OutgoingMessage, CommittableIncomingMessage>>

Constructors

AmqpRpcFlowStage(AmqpSinkSettings, Int32, Int32)

Declaration

public AmqpRpcFlowStage(AmqpSinkSettings settings, int bufferSize, int responsePerMessage = 1)

Parameters

Type	Name	Description
AmqpSinkSettings	settings
Int32	bufferSize
Int32	responsePerMessage

Fields

DefaultAttributes

Declaration

public static readonly Attributes DefaultAttributes

Field Value

Type	Description
Akka.Streams.Attributes

In

Declaration

public readonly Inlet<OutgoingMessage> In

Field Value

Type	Description
Akka.Streams.Inlet<OutgoingMessage>

Out

Declaration

public readonly Outlet<CommittableIncomingMessage> Out

Field Value

Type	Description
Akka.Streams.Outlet<CommittableIncomingMessage>

Properties

BufferSize

Declaration

public int BufferSize { get; }

Property Value

Type	Description
Int32

InitialAttributes

Declaration

protected override Attributes InitialAttributes { get; }

Property Value

Type	Description
Akka.Streams.Attributes

Overrides

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.FlowShape<Akka.Streams.Amqp.RabbitMq.OutgoingMessage, Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, System.Threading.Tasks.Task<System.String>>.InitialAttributes

ResponsePerMessage

Declaration

public int ResponsePerMessage { get; }

Property Value

Type	Description
Int32

Settings

Declaration

public AmqpSinkSettings Settings { get; }

Property Value

Type	Description
AmqpSinkSettings

Shape

Declaration

public override FlowShape<OutgoingMessage, CommittableIncomingMessage> Shape { get; }

Property Value

Type	Description
Akka.Streams.FlowShape<OutgoingMessage, CommittableIncomingMessage>

Overrides

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.FlowShape<Akka.Streams.Amqp.RabbitMq.OutgoingMessage, Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, System.Threading.Tasks.Task<System.String>>.Shape

Methods

CreateLogicAndMaterializedValue(Attributes)

Declaration

public override ILogicAndMaterializedValue<Task<string>> CreateLogicAndMaterializedValue(Attributes inheritedAttributes)

Parameters

Type	Name	Description
Akka.Streams.Attributes	inheritedAttributes

Returns

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

Overrides

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.FlowShape<Akka.Streams.Amqp.RabbitMq.OutgoingMessage, Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, System.Threading.Tasks.Task<System.String>>.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>