Class AmqpSourceStage

Connects to an AMQP server upon materialization and consumes messages from it emitting them into the stream. Each materialized source will create one connection to the broker. As soon as an IncomingMessage is sent downstream, an ack for it is sent to the broker.

Inheritance

Object

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SourceShape<CommittableIncomingMessage>, Akka.NotUsed>

Akka.Streams.Stage.GraphStage<Akka.Streams.SourceShape<CommittableIncomingMessage>>

AmqpSourceStage

Implements

Akka.Streams.Stage.IGraphStageWithMaterializedValue<Akka.Streams.SourceShape<CommittableIncomingMessage>, Akka.NotUsed>

Akka.Streams.IGraph<Akka.Streams.SourceShape<CommittableIncomingMessage>, Akka.NotUsed>

Akka.Streams.IGraph<Akka.Streams.SourceShape<CommittableIncomingMessage>>

Inherited Members

Akka.Streams.Stage.GraphStage<Akka.Streams.SourceShape<Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>>.CreateLogicAndMaterializedValue(Akka.Streams.Attributes)

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SourceShape<Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, Akka.NotUsed>.WithAttributes(Akka.Streams.Attributes)

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SourceShape<Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, Akka.NotUsed>.CreateLogicAndMaterializedValue(Akka.Streams.Attributes)

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SourceShape<Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, Akka.NotUsed>.AddAttributes(Akka.Streams.Attributes)

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SourceShape<Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, Akka.NotUsed>.Named(System.String)

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SourceShape<Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, Akka.NotUsed>.Async()

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SourceShape<Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, Akka.NotUsed>.InitialAttributes

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SourceShape<Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, Akka.NotUsed>.Shape

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SourceShape<Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, Akka.NotUsed>.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 AmqpSourceStage : GraphStage<SourceShape<CommittableIncomingMessage>>, IGraphStageWithMaterializedValue<SourceShape<CommittableIncomingMessage>, NotUsed>, IGraph<SourceShape<CommittableIncomingMessage>, NotUsed>, IGraph<SourceShape<CommittableIncomingMessage>>

Constructors

| Improve this Doc View Source

AmqpSourceStage(IAmqpSourceSettings, Int32)

Constructor

Declaration

public AmqpSourceStage(IAmqpSourceSettings settings, int bufferSize)

Parameters

Type	Name	Description
IAmqpSourceSettings	settings	The source settings
Int32	bufferSize	The max number of elements to prefetch and buffer at any given time.

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

Out

Declaration

public readonly Outlet<CommittableIncomingMessage> Out

Field Value

Type	Description
Akka.Streams.Outlet<CommittableIncomingMessage>

Properties

| Improve this Doc View Source

BufferSize

Declaration

public int BufferSize { get; }

Property Value

Type	Description
Int32

| 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.SourceShape<Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, Akka.NotUsed>.InitialAttributes

| Improve this Doc View Source

Settings

Declaration

public IAmqpSourceSettings Settings { get; }

Property Value

Type	Description
IAmqpSourceSettings

| Improve this Doc View Source

Shape

Declaration

public override SourceShape<CommittableIncomingMessage> Shape { get; }

Property Value

Type	Description
Akka.Streams.SourceShape<CommittableIncomingMessage>

Overrides

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.SourceShape<Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>, Akka.NotUsed>.Shape

Methods

| Improve this Doc View Source

CreateLogic(Attributes)

Declaration

protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)

Parameters

Type	Name	Description
Akka.Streams.Attributes	inheritedAttributes

Returns

Type	Description
Akka.Streams.Stage.GraphStageLogic

Overrides

Akka.Streams.Stage.GraphStage<Akka.Streams.SourceShape<Akka.Streams.Amqp.RabbitMq.Dsl.CommittableIncomingMessage>>.CreateLogic(Akka.Streams.Attributes)

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