Namespace Akka.Streams.Amqp.RabbitMq
Classes
AckArguments
AmqpConnectionDetails
AmqpConnectionUri
AmqpFlowStage<TPassThrough>
This stage materializes to a Task
AmqpReplyToSinkSettings
AmqpReplyToSinkStage
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.
AmqpRpcFlowStage
This stage materializes to a Task<TResult>, which is the name of the private exclusive queue used for RPC communication
AmqpSinkSettings
AmqpSinkStage
Connects to an AMQP server upon materialization and sends incoming messages to the server. Each materialized sink will create one connection to the broker.
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.
BindingDeclaration
CommitCallback
DefaultAmqpConnection
Connects to a local AMQP broker at the default port with no password.
Envelope
Encapsulates a group of parameters used for AMQP's Basic methods
ExchangeDeclaration
IncomingMessage
NackArguments
NamedQueueSourceSettings
OutgoingMessage
QueueDeclaration
ShutdownSignalException
TemporaryQueueSourceSettings
Structs
AmqpCredentials
Interfaces
IAmqpConnectionSettings
Only for internal implementations