Namespace RabbitMQ.AMQP.Client
Classes
- BackOffDelayPolicy
Class for the backoff delay policy. Used during the recovery of the connection.
- BadRequestException
Thrown when management response is code 400, bad request.
- ByteCapacity
Class for specifying a binary size, with units
- ConnectionException
Exception related to IConnection
- ConsumerException
Exception returned during consumer operations. See IConsumer.
- IConsumerBuilder.ListenerContext
ListenerContext is a helper class that holds the contexts for the listener
- InvalidCodeException
Thrown when management response code is not expected.
- ModelException
Thrown when management response code or correlation ID mismatch.
- PreconditionFailedException
Thrown when management response is "precondition failed".
- PublishOutcome
Represents the outcome of a publish operation. It contains the state of the outcome and an error if the outcome is not successful.
- PublishResult
Represents the result of a publish operation. It contains the PublishOutcome and the original IMessage.
- RecoveryConfiguration
RecoveryConfiguration is a class that represents the configuration of the recovery of the topology. It is used to configure the recovery of the topology of the server after a connection is established in case of a reconnection The RecoveryConfiguration can be disabled or enabled. If RecoveryConfiguration._active is disabled, the reconnect mechanism will not be activated. If RecoveryConfiguration._topology is disabled, the recovery of the topology will not be activated.
Interfaces
- IBackOffDelayPolicy
Interface for the backoff delay policy. Used during the recovery of the connection.
- IConsumer
API to consume messages from a RabbitMQ queue.
Instances are configured and created with a IConsumerBuilder.
See ConsumerBuilder() and IConsumerBuilder.
- IConsumerBuilder.IStreamFilterOptions
Filter options for support of AMQP filter expressions.
AMQP filter expressions are supported only with streams. This a different filtering mechanism from stream filtering. Both mechanisms can be used together. Requires RabbitMQ 4.1 or more.
- IEntityInfoSpecification<T>
Generic interface for managing entities with result of type T
- IEntitySpecification
Generic interface for specifying entities without result
- IEnvironment
The IEnvironment is the main entry point to a node or a cluster of nodes.
The CreateConnectionAsync() method allows creating IConnection instances. An application is expected to maintain a single IEnvironment instance and to close that instance upon application exit.
IEnvironment instances are expected to be thread-safe.
- IManagement
The IManagement interface is used to manage the AMQP 0.9.1 model topology (exchanges, queues, and bindings).
- IPublisher
Interface for publishing messages to an AMQP broker. Implementations of this interface are expected to be thread-safe.
- IRecoveryConfiguration
Interface for the recovery configuration.
- IRpcClient
IRpcClient is the interface for an RPC client. See also IRpcServer and IRpcClientBuilder
- IRpcClientBuilder
IRpcClientBuilder is the interface for creating an RPC client. See also IRpcClient and IRpcServerBuilder
- IRpcServer
IRpcServer interface for creating an RPC server. The RPC is simulated by sending a request message and receiving a reply message. Where the client sends the queue where wants to receive the reply. RPC client ---> request queue ---> RPC server ---> reply queue ---> RPC client See also IRpcClient
- IRpcServerBuilder
IRpcServerBuilder is the interface for creating an RPC server. The RPC server consumes requests from a queue and sends replies to a reply queue. See also IRpcServer and IRpcClientBuilder
Enums
- OutcomeState
Represents the status of a publish operation. See AMQP Outcomes.
Delegates
- MessageHandler
Delegate to process an incoming message.
- RpcHandler
Event handler for handling RPC requests.