Namespace RabbitMQ.Client
Classes
- AmqpTcpEndpoint
Represents a TCP-addressable AMQP peer: a host name and port number.
- BasicGetResult
Represents Basic.GetOk responses from the server.
- BasicProperties
AMQP specification content header properties for content class "basic".
- BinaryTableValue
Wrapper for a byte[]. May appear as values read from and written to AMQP field tables.
- CachedString
Caches a string's byte representation to be used for certain methods like IChannel.BasicPublish/>.
- ConnectionConfig
The configuration of a connection.
- ConnectionFactory
Main entry point to the RabbitMQ .NET AMQP client API. Constructs IConnection instances.
- CreateChannelOptions
Channel creation options.
- ExchangeType
Convenience class providing compile-time names for standard exchange types.
- Headers
Convenience class providing compile-time names for standard headers.
- PublicationAddress
Container for an exchange name, exchange type and routing key, usable as the target address of a message to be published.
- QueueDeclareOk
Represents Queue info.
- ReadOnlyBasicProperties
AMQP specification content header properties for content class "basic"
- ShutdownReportEntry
Single entry object in the shutdown report that encapsulates description of the error which occurred during shutdown.
- SslOption
Represents a set of configurable TLS options for a connection. Use this class to configure TLS version used, client certificate list or file location, peer certificate verification (validation) functions, expected server name (Subject Alternative Name or Common Name), and so on.
- TcpClientAdapter
Simple wrapper around Socket.
- ThrottlingRateLimiter
A rate limiter that controls the rate of operations by limiting concurrency and applying delays when a specified threshold of concurrency usage is reached.
The delay algorithm checks the current available permits from the concurrency limiter. If the available permits are greater than or equal to the throttling threshold, no delay is applied. Otherwise, it calculates a delay based on the percentage of permits used, scaling it up to a maximum of 1000 milliseconds.
- TopologyRecoveryExceptionHandler
Custom logic for handling topology recovery exceptions that match the specified filters.
- TopologyRecoveryFilter
Filter to know which entities (exchanges, queues, bindings, consumers) should be recovered by topology recovery. By default, allows all entities to be recovered.
Structs
- AmqpTimestamp
Structure holding an AMQP timestamp, a posix 64-bit time_t.
Interfaces
- IAmqpHeader
A AMQP header.
- IAmqpWriteable
A AMQP writeable.
- IAsyncBasicConsumer
Consumer interface. Used to receive messages from a queue by subscription.
- IAuthMechanism
A pluggable authentication mechanism.
- IBasicProperties
The AMQP Basic headers class interface, spanning the union of the functionality offered by versions 0-8, 0-8qpid, 0-9 and 0-9-1 of AMQP.
- IChannel
Common AMQP model, spanning the union of the functionality offered by versions 0-8, 0-8qpid, 0-9 and 0-9-1 of AMQP.
- IConnection
Main interface to an AMQP connection.
- INetworkConnection
Common interface for network (TCP/IP) connection classes.
- IProtocol
Object describing various overarching parameters associated with a particular AMQP protocol variant.
- IReadOnlyBasicProperties
The AMQP Basic headers class interface, spanning the union of the functionality offered by versions 0-8, 0-8qpid, 0-9 and 0-9-1 of AMQP.
- IRecoverable
A marker interface for entities that are recoverable (currently connection or channel).
- ITcpClient
Wrapper interface for Socket. Provides the socket for socket frame handler class.
Enums
- DeliveryModes
Convenience enum providing compile-time names for persistent modes.
- ShutdownInitiator
Describes the source of a shutdown event.