Master Index

Namespaces

Namespace Summary
RabbitMQ.Client

Main public API to the RabbitMQ .NET AMQP client library.

RabbitMQ.Client.Content

Public API for construction and analysis of messages that are binary-compatible with messages produced and consumed by QPid's JMS compatibility layer.

RabbitMQ.Client.Events

Public API for various events and event handlers that are part of the AMQP client library.

RabbitMQ.Client.Exceptions

Public API for exceptions visible to the user of the AMQP client library.

RabbitMQ.Client.MessagePatterns

Public API for high-level helper classes and interface for common ways of using the AMQP client library.

RabbitMQ.Util

Internal. Utility classes.

Types

Type Summary
RabbitMQ.Client.AmqpTcpEndpoint

Represents a TCP-addressable AMQP peer: a host name and port number.

RabbitMQ.Client.AmqpTimestamp

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

RabbitMQ.Client.AmqpVersion

Represents a version of the AMQP specification.

RabbitMQ.Client.AuthMechanism

A pluggable authentication mechanism.

RabbitMQ.Client.AuthMechanismFactory

(undocumented)

RabbitMQ.Client.BasicGetResult

Represents Basic.GetOk responses from the server.

RabbitMQ.Client.BinaryTableValue

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

RabbitMQ.Client.ConnectionFactory

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

RabbitMQ.Client.ConnectionFactory.<>c__DisplayClass3

(undocumented)

RabbitMQ.Client.ConnectionFactoryBase

(undocumented)

RabbitMQ.Client.ConsumerWorkService

(undocumented)

RabbitMQ.Client.Content.BasicMessageBuilder

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

RabbitMQ.Client.Content.BasicMessageReader

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

RabbitMQ.Client.Content.BytesMessageBuilder

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

RabbitMQ.Client.Content.BytesMessageReader

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

RabbitMQ.Client.Content.BytesWireFormatting

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

RabbitMQ.Client.Content.IBytesMessageBuilder

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

RabbitMQ.Client.Content.IBytesMessageReader

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

RabbitMQ.Client.Content.IMapMessageBuilder

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

RabbitMQ.Client.Content.IMapMessageReader

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

RabbitMQ.Client.Content.IMessageBuilder

Interface for constructing application messages.

RabbitMQ.Client.Content.IMessageReader

Interface for analyzing application messages.

RabbitMQ.Client.Content.IStreamMessageBuilder

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

RabbitMQ.Client.Content.IStreamMessageReader

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

RabbitMQ.Client.Content.MapMessageBuilder

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

RabbitMQ.Client.Content.MapMessageReader

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

RabbitMQ.Client.Content.MapWireFormatting

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

RabbitMQ.Client.Content.PrimitiveParser

Utility class for extracting typed values from strings.

RabbitMQ.Client.Content.StreamMessageBuilder

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

RabbitMQ.Client.Content.StreamMessageReader

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

RabbitMQ.Client.Content.StreamWireFormatting

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

RabbitMQ.Client.Content.StreamWireFormattingTag

Tags used in parsing and generating StreamWireFormatting message bodies.

RabbitMQ.Client.DefaultBasicConsumer

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

RabbitMQ.Client.Events.BaseExceptionEventArgs

(undocumented)

RabbitMQ.Client.Events.BasicAckEventArgs

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

RabbitMQ.Client.Events.BasicDeliverEventArgs

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

RabbitMQ.Client.Events.BasicNackEventArgs

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

RabbitMQ.Client.Events.BasicReturnEventArgs

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

RabbitMQ.Client.Events.CallbackExceptionEventArgs

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

RabbitMQ.Client.Events.ConnectionBlockedEventArgs

Event relating to connection being blocked.

RabbitMQ.Client.Events.ConsumerEventArgs

Event relating to a successful consumer registration or cancellation.

RabbitMQ.Client.Events.ConsumerTagChangedAfterRecoveryEventArgs

(undocumented)

RabbitMQ.Client.Events.EventingBasicConsumer

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

RabbitMQ.Client.Events.FlowControlEventArgs

Event relating to flow control.

RabbitMQ.Client.Events.QueueNameChangedAfterRecoveryEventArgs

(undocumented)

RabbitMQ.Client.Events.RecoveryExceptionEventArgs

Describes an exception that was thrown during automatic connection recovery performed by the library.

RabbitMQ.Client.Exceptions.AlreadyClosedException

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

RabbitMQ.Client.Exceptions.AuthenticationFailureException

Thrown when the cause is an authentication failure.

RabbitMQ.Client.Exceptions.BrokerUnreachableException

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

RabbitMQ.Client.Exceptions.ChannelAllocationException

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

RabbitMQ.Client.Exceptions.ConnectFailureException

Thrown when a connection to the broker fails

RabbitMQ.Client.Exceptions.OperationInterruptedException

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.

RabbitMQ.Client.Exceptions.PacketNotRecognizedException

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.

RabbitMQ.Client.Exceptions.PossibleAuthenticationFailureException

Thrown when the likely cause is an authentication failure.

RabbitMQ.Client.Exceptions.ProtocolVersionMismatchException

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

RabbitMQ.Client.Exceptions.UnexpectedMethodException

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

RabbitMQ.Client.Exceptions.UnsupportedMethodException

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

RabbitMQ.Client.Exceptions.UnsupportedMethodFieldException

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.

RabbitMQ.Client.Exceptions.WireFormattingException

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

RabbitMQ.Client.ExchangeType

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

RabbitMQ.Client.ExternalMechanism

(undocumented)

RabbitMQ.Client.ExternalMechanismFactory

(undocumented)

RabbitMQ.Client.IBasicConsumer

Consumer interface. Used to receive messages from a queue by subscription.

RabbitMQ.Client.IBasicProperties

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

RabbitMQ.Client.IConnection

Main interface to an AMQP connection.

RabbitMQ.Client.IConnectionFactory

(undocumented)

RabbitMQ.Client.IContentHeader

A decoded AMQP content header frame.

RabbitMQ.Client.IMethod

A decoded AMQP method frame.

RabbitMQ.Client.IModel

Common AMQP model, spanning the union of the functionality offered by versions 0-8, 0-8qpid, 0-9 and 0-9-1 of AMQP.

RabbitMQ.Client.IProtocol

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

RabbitMQ.Client.IQueueingBasicConsumer

(undocumented)

RabbitMQ.Client.IRecoverable

A marker interface for entities that are recoverable (currently connection or channel).

RabbitMQ.Client.IStreamProperties

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

RabbitMQ.Client.MessagePatterns.ISubscription

(undocumented)

RabbitMQ.Client.MessagePatterns.SimpleRpcClient

Implements a simple RPC client.

RabbitMQ.Client.MessagePatterns.SimpleRpcServer

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

RabbitMQ.Client.MessagePatterns.Subscription

Manages a subscription to a queue.

RabbitMQ.Client.NetworkConnection

Common interface for network (TCP/IP) connection classes.

RabbitMQ.Client.PlainMechanism

(undocumented)

RabbitMQ.Client.PlainMechanismFactory

(undocumented)

RabbitMQ.Client.Protocols

Provides access to the supported implementations.

RabbitMQ.Client.PublicationAddress

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

RabbitMQ.Client.QueueDeclareOk

Represents Queue info.

RabbitMQ.Client.QueueingBasicConsumer

A implementation that uses a to buffer incoming deliveries.

RabbitMQ.Client.ShutdownEventArgs

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

RabbitMQ.Client.ShutdownInitiator

Describes the source of a shutdown event.

RabbitMQ.Client.ShutdownReportEntry

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

RabbitMQ.Client.SslHelper

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

RabbitMQ.Client.SslOption

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

RabbitMQ.Client.TopologyRecoveryException

(undocumented)

RabbitMQ.Util.BatchingWorkPool<K,V>

(undocumented)

RabbitMQ.Util.BlockingCell

A thread-safe single-assignment reference cell.

RabbitMQ.Util.DebugUtil

Miscellaneous debugging and development utilities.

RabbitMQ.Util.Either

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

RabbitMQ.Util.EitherAlternative

Used internally by class Either.

RabbitMQ.Util.IntAllocator

(undocumented)

RabbitMQ.Util.IntAllocator.IntervalList

(undocumented)

RabbitMQ.Util.NetworkBinaryReader

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

RabbitMQ.Util.NetworkBinaryWriter

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

RabbitMQ.Util.SetQueue<T>

(undocumented)

RabbitMQ.Util.SharedQueue

A thread-safe shared queue implementation.

RabbitMQ.Util.SharedQueue<T>

A thread-safe shared queue implementation.

RabbitMQ.Util.SharedQueueEnumerator<T>

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

RabbitMQ.Util.SynchronizedList<T>

(undocumented)

RabbitMQ.Util.XmlUtil

Miscellaneous helpful XML utilities.