Master Index

Represents a TCP-addressable AMQP peer, including the protocol variant to use, and a host name and port number.

Structure holding an AMQP timestamp, a posix 64-bit time_t.

Represents a version of the AMQP specification.

Represents Basic.GetOk responses from the server.

Wrapper for a byte[]. May appear as values read from and written to AMQP field tables.

Main entry point to the RabbitMQ .NET AMQP client API. Constructs IConnection instances.

Supplies values to ConnectionFactory for use in constructing IConnection instances.

Framework for constructing various types of AMQP Basic-class application messages.

Framework for analyzing various types of AMQP Basic-class application messages.

Constructs AMQP Basic-class messages binary-compatible with QPid's "BytesMessage" wire encoding.

Analyzes AMQP Basic-class messages binary-compatible with QPid's "BytesMessage" wire encoding.

Internal support class for use in reading and writing information binary-compatible with QPid's "BytesMessage" wire encoding.

Interface for constructing messages binary-compatible with QPid's "BytesMessage" wire encoding.

Analyzes messages binary-compatible with QPid's "BytesMessage" wire encoding.

Interface for constructing messages binary-compatible with QPid's "MapMessage" wire encoding.

Analyzes messages binary-compatible with QPid's "MapMessage" wire encoding.

Interface for constructing application messages.

Interface for analyzing application messages.

Interface for constructing messages binary-compatible with QPid's "StreamMessage" wire encoding.

Analyzes messages binary-compatible with QPid's "StreamMessage" wire encoding.

Constructs AMQP Basic-class messages binary-compatible with QPid's "MapMessage" wire encoding.

Analyzes AMQP Basic-class messages binary-compatible with QPid's "MapMessage" wire encoding.

Internal support class for use in reading and writing information binary-compatible with QPid's "MapMessage" wire encoding.

Utility class for extracting typed values from strings.

Constructs AMQP Basic-class messages binary-compatible with QPid's "StreamMessage" wire encoding.

Analyzes AMQP Basic-class messages binary-compatible with QPid's "StreamMessage" wire encoding.

Internal support class for use in reading and writing information binary-compatible with QPid's "StreamMessage" wire encoding.

Tags used in parsing and generating StreamWireFormatting message bodies.

Useful default/base implementation of IBasicConsumer. Subclass and override HandleBasicDeliver in application code.

Contains all the information about a message delivered from an AMQP broker within the Basic content-class.

Delegate used to process Basic.Deliver events.

Contains all the information about a message returned from an AMQP broker within the Basic content-class.

Delegate used to process Basic.Return events.

Describes an exception that was thrown during the library's invocation of an application-supplied callback handler.

Callback invoked when other callbacks throw unexpected exceptions.

Delegate used to process connection shutdown notifications.

Event relating to a successful consumer registration or cancellation.

Callback for events relating to consumer registration and cancellation.

Callback for events relating to consumer shutdown.

Experimental class exposing an IBasicConsumer's methods as separate events.

Delegate used to process model shutdown notifications.

Thrown when the application tries to make use of a session or connection that has already been shut down.

Thrown when no connection could be opened during a ConnectionFactory.CreateConnection attempt.

Thrown when a SessionManager cannot allocate a new channel number, or the requested channel number is already in use.

Thrown when a session is destroyed during an RPC call to a broker. For example, if a TCP connection dropping causes the destruction of a session in the middle of a QueueDeclare operation, an OperationInterruptedException will be thrown to the caller of IModel.QueueDeclare.

Thrown to indicate that the peer didn't understand the packet received from the client. Peer sent default message describing protocol version it is using and transport parameters.

Thrown to indicate that the peer does not support the wire protocol version we requested immediately after opening the TCP socket.

Thrown when the model receives an RPC reply that it wasn't expecting.

Thrown when the model receives an RPC request it cannot satisfy.

Thrown when the model cannot transmit a method field because the version of the protocol the model is implementing does not contain a definition for the field in question.

Thrown when the wire-formatting code cannot encode a particular .NET value to AMQP protocol format.

Convenience class providing compile-time names for various exchange types.

Consumer interface for Basic content-class. Used to receive messages from a queue by subscription.

Common AMQP Basic content-class headers interface, spanning the union of the functionality offered by versions 0-8, 0-8qpid and 0-9 (without WIP) of AMQP.

Main interface to an AMQP connection.

A decoded AMQP content header frame.

Common AMQP File content-class headers interface, spanning the union of the functionality offered by versions 0-8, 0-8qpid and 0-9 (without WIP) of AMQP.

A decoded AMQP method frame.

Common AMQP model, spanning the union of the functionality offered by versions 0-8, 0-8qpid, and 0-9 (without WIP) of AMQP.

Object describing various overarching parameters associated with a particular AMQP protocol variant.

Common AMQP Stream content-class headers interface, spanning the union of the functionality offered by versions 0-8, 0-8qpid and 0-9 (without WIP) of AMQP.

Implements a simple RPC client.

Implements a simple RPC service, responding to requests received via a Subscription.

Manages a subscription to a queue or exchange.

Concrete, predefined IProtocol instances ready for use with ConnectionFactory.

Container for an exchange name, exchange type and routing key, usable as the target address of a message to be published.

Simple IBasicConsumer implementation that uses a SharedQueue to buffer incoming deliveries.

Information about the reason why a particular model, session, or connection was destroyed.

Describes the source of a shutdown event.

Single entry object in the shutdown report that encapsulates description of the error which occured during shutdown

Represents an SslHelper which does the actual heavy lifting to set up an SSL connection, using the config options in an SslOption to make things cleaner

Represents a configurable SSL option, used in setting up an SSL connection.

A thread-safe single-assignment reference cell.

Miscellaneous debugging and development utilities.

Models the disjoint union of two alternatives, a "left" alternative and a "right" alternative.

Used internally by class Either.

Subclass of BinaryReader that reads integers etc in correct network order.

Subclass of BinaryWriter that writes integers etc in correct network order.

A thread-safe shared queue implementation.

Implementation of the IEnumerator interface, for permitting SharedQueue to be used in foreach loops.

Miscellaneous helpful XML utilities.