Class AmqpSink

Inheritance

Object

AmqpSink

Inherited Members

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.Streams.Amqp.RabbitMq.Dsl

Assembly: Akka.Streams.Amqp.RabbitMq.dll

Syntax

public static class AmqpSink

Methods

Create(AmqpSinkSettings)

Creates an AmqpSink that accepts OutgoingMessage elements.

Declaration

public static Sink<OutgoingMessage, Task> Create(AmqpSinkSettings settings)

Parameters

Type	Name	Description
AmqpSinkSettings	settings	The sink settings

Returns

Type	Description
Akka.Streams.Dsl.Sink<OutgoingMessage, Task>	an AmqpSink that accepts OutgoingMessage elements.

CreateSimple(AmqpSinkSettings)

Creates an AmqpSink that accepts Akka.IO.ByteString elements.

Declaration

public static Sink<ByteString, Task> CreateSimple(AmqpSinkSettings settings)

Parameters

Type	Name	Description
AmqpSinkSettings	settings	the sink settings

Returns

Type	Description
Akka.Streams.Dsl.Sink<Akka.IO.ByteString, Task>	an AmqpSink that accepts Akka.IO.ByteString elements.

ReplyTo(AmqpReplyToSinkSettings)

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. This stage materializes to a Future[Done], which can be used to know when the Sink completes, either normally or because of an amqp failure

Declaration

public static Sink<OutgoingMessage, Task> ReplyTo(AmqpReplyToSinkSettings settings)

Parameters

Type	Name	Description
AmqpReplyToSinkSettings	settings

Returns

Type	Description
Akka.Streams.Dsl.Sink<OutgoingMessage, Task>