Class AmqpFlow

Inheritance
Object
AmqpFlow
Inherited Members
Namespace: Akka.Streams.Amqp.RabbitMq.Dsl
Assembly: Akka.Streams.Amqp.RabbitMq.dll
Syntax
public static class AmqpFlow

Methods

| Improve this Doc View Source

Create<TPassThrough>(AmqpSinkSettings)

Create a flow that publishes messages to RabbitMQ.

Declaration
public static Flow<(OutgoingMessage, TPassThrough), TPassThrough, Task> Create<TPassThrough>(AmqpSinkSettings settings)
Parameters
Type Name Description
AmqpSinkSettings settings
Returns
Type Description
Akka.Streams.Dsl.Flow<System.ValueTuple<OutgoingMessage, TPassThrough>, TPassThrough, Task>

TBD
Type Parameters
Name Description
TPassThrough