| Address | A representation of network addresses, i.e. |
| AlreadyClosedException | |
| AMQBasicProperties | |
| AMQChannel | Base class modelling an AMQ channel. |
| AMQChannel.BlockingRpcContinuation<T> | |
| AMQChannel.RpcContinuation | |
| AMQChannel.SimpleBlockingRpcContinuation | |
| AMQCommand | AMQ-specific implementation of Command which accumulates
method, header and body from a series of frames, unless these are
supplied at construction time. |
| AMQConnection | Concrete class representing and managing an AMQP connection to a broker. |
| AMQContentHeader | Implementation of ContentHeader - specialized by autogenerated code in AMQP.java. |
| BasicProperties | |
| BlockingCell<T> | Simple one-shot IPC mechanism. |
| BlockingValueOrException<V, E extends Throwable & SensibleClone<E>> |
| Channel | Public API: Interface to an AMQ channel. |
| ChannelManager | Manages a set of channels, indexed by channel number (1.._channelMax). |
| ChannelN | Main interface to AMQP protocol functionality. |
| Command | Interface to a container for an AMQP method-and-arguments, with optional content header and body. |
| ConfirmListener | Implement this interface in order to be notified of Confirm events. |
| Connection | Public API: Interface to an AMQ connection. |
| ConnectionFactory | Convenience "factory" class to facilitate opening a Connection to an AMQP broker. |
| Consumer | Interface for application callback objects to receive notifications and messages from a queue by subscription. |
| ConsumerCancelledException | |
| ContentHeader | Public API for abstract AMQP content header objects. |
| ContentHeaderPropertyReader | Parses an AMQP wire-protocol ContentHeader from a
DataInputStream. |
| ContentHeaderPropertyWriter | Generates an AMQP wire-protocol packet from a ContentHeader. |
| CRDemoMechanism | Provides equivalent security to PLAIN but demos use of Connection.Secure(Ok) START-OK: Username SECURE: "Please tell me your password" SECURE-OK: Password |
| CRDemoMechanism.CRDemoSaslConfig |
| DefaultConsumer | Convenience class providing a default implementation of Consumer. |
| DefaultExceptionHandler | |
| DefaultSaslConfig | Default SASL configuration. |
| Envelope | Encapsulates a group of parameters used for AMQP's Basic methods |
| ExceptionHandler | Interface to an exception-handling object. |
| ExternalMechanism | The EXTERNAL auth mechanism |
| FlowListener | Implement this interface in order to be notified of Channel.Flow events. |
| Frame | Represents an AMQP wire-protocol frame, with frame type, channel number, and payload bytes. |
| FrameHandler | Interface to a frame handler. |
| GetResponse | Encapsulates the response from a basicGet(String, boolean) message-retrieval method call
- essentially a static bean "holder" with message response data. |
| IntAllocator | A class for allocating integers from a given range that uses a BitSet representation of the free integers. |
| JDKSaslConfig | Implementation of SaslConfig that uses the JDK SASL implementation. |
| JSONReader | |
| JsonRpcClient | JSON-RPC is a lightweight RPC mechanism using JSON as a data language for request and reply messages. |
| JsonRpcException | Thrown when a JSON-RPC service indicates an error occurred during a call. |
| JsonRpcServer | JSON-RPC Server class. |
| JSONSerializable | Interface for classes that wish to control their own serialization. |
| JSONUtil | Utility methods for working with JSON objects in Java. |
| JSONWriter |
| LongString | An object providing access to a LongString. |
| LongStringHelper | Utility for working with LongStrings. |
| MalformedFrameException | Encapsulates a frame format error at the wire level. |
| MapRpcServer | Subclass of RpcServer which uses AMQP wire-format encoded tables as requests and replies. |
| MessageProperties | Constant holder class with useful static instances of AMQContentHeader. |
| Method | Public interface to objects representing an AMQP method - see the spec for details. |
| Method | Base class for AMQP method objects, specialized by autogenerated code in AMQP.java. |
| MethodArgumentReader | Parses AMQP wire-protocol Method arguments from a
DataInputStream. |
| MethodArgumentWriter | Generates AMQP wire-protocol encoded arguments. |
| MissedHeartbeatException | Encapsulates an exception indicating that the connection has missed too many heartbeats and is being shut down. |
| NullTrustManager | Convenience class providing a default implementation of javax.net.ssl.X509TrustManager. |
| ParameterDescription | Description of a single JSON-RPC procedure parameter. |
| PlainMechanism | The PLAIN auth mechanism |
| PossibleAuthenticationFailureException | Thrown when the likely cause is an authentication failure. |
| ProcedureDescription | Description of a single JSON-RPC procedure. |
| ProtocolVersionMismatchException | Thrown to indicate that the server does not support the wire protocol version we requested immediately after opening the TCP socket. |
| QueueingConsumer | Convenience class: an implementation of Consumer with
straightforward blocking semantics. |
| QueueingConsumer.Delivery | Encapsulates an arbitrary message - simple "bean" holder structure. |
| ReturnListener | Implement this interface in order to be notified of failed deliveries when basicPublish is called with "mandatory" or "immediate" flags set. |
| RpcClient | Convenience class which manages a temporary reply queue for simple RPC-style communication. |
| RpcServer | Class which manages a request queue for a simple RPC-style service. |
| SaslConfig | This interface represents a hook to allow you to control how exactly a sasl client is selected during authentication. |
| SaslMechanism | Our own view of a SASL authentication mechanism, introduced to remove a dependency on javax.security.sasl. |
| SensibleClone<T extends SensibleClone<T>> | This interface exists as a workaround for the annoyingness of java.lang.Cloneable. |
| ServiceDescription | Description of a JSON-RPC service. |
| SetQueue<T> | A generic queue-like implementation (supporting operations addIfNotPresent,
poll, contains, and isEmpty)
which restricts a queue element to appear at most once. |
| ShutdownListener | |
| ShutdownNotifier | Interface for components that are shutdown capable and that allow listeners to be added for shutdown signals |
| ShutdownNotifierComponent | |
| ShutdownSignalException | Encapsulates a shutdown condition for a connection to an AMQP broker. |
| SingleShotLinearTimer | This class provides a very stripped-down clone of some of the functionality in java.util.Timer (notably Timer.schedule(TimerTask task, long delay) but uses System.nanoTime() rather than System.currentTimeMillis() as a measure of the underlying time, and thus behaves correctly if the system clock jumps around. |
| SocketFrameHandler | A socket-based frame handler. |
| StringRpcServer | Subclass of RpcServer which accepts UTF-8 string requests. |
| Tracer | AMQP Protocol Analyzer program. |
| Tracer.AsyncLogger | A Tracer.Logger designed to print Strings to a designated OutputStream
on a private thread. |
| Tracer.Logger | Logging strings to an outputStream. |
| TruncatedInputStream | Utility stream: proxies another stream, making it appear to be no longer than a preset limit. |
| UnexpectedFrameError | Thrown when the command parser hits an unexpected frame type. |
| UnexpectedMethodError | Indicates that a Method object was supplied that was not
expected. |
| UnknownClassOrMethodId | Thrown when the protocol handlers detect an unknown class number or method number. |
| Utility | Catch-all holder class for static helper methods. |
| ValueOrException<V, E extends Throwable & SensibleClone<E>> | |
| ValueReader | Helper class to read AMQP wire-protocol encoded values. |
| ValueWriter | Helper class to generate AMQP wire-protocol encoded values. |
| Version | Encapsulation of AMQP protocol version |
| WorkPool<K, W> | This is a generic implementation of the Channelsspecification in Channeling Work, Nov 2010 (channels.pdf). |