All Classes and Interfaces
Class
Description
A representation of network addresses, i.e.
Thrown when application tries to perform an action on connection/channel
which was already closed
Base class modelling an AMQ channel.
AMQ-specific implementation of
Command which accumulates
method, header and body from a series of frames, unless these are
supplied at construction time.Concrete class representing and managing an AMQP connection to a broker.
Implementation of ContentHeader - specialized by autogenerated code in AMQP.java.
Thrown when the broker refuses access due to an authentication failure.
Channel implementation that is automatically
recovered during connection recovery.Connection implementation that performs automatic recovery when
connection shutdown is not initiated by the application (e.g.
Implement this interface in order to be notified of connection block and
unblock events.
Simple one-shot IPC mechanism.
Interface to a channel.
Manages a set of channels, indexed by channel number (
1.._channelMax).Main interface to AMQP protocol functionality.
Publicly available Client Version information
Interface to a container for an AMQP method-and-arguments, with optional content header and body.
Implement this interface in order to be notified of Confirm events.
Public API: Interface to an AMQ connection.
Convenience "factory" class to facilitate opening a
Connection to an AMQP broker.Interface for application callback objects to receive notifications and messages from
a queue by subscription.
Not part of the public API.
Public API for abstract AMQP content header objects.
Parses an AMQP wire-protocol
ContentHeader from a
DataInputStream.Generates an AMQP wire-protocol packet from a
ContentHeader.Provides equivalent security to PLAIN but demos use of Connection.Secure(Ok)
START-OK: Username
SECURE: "Please tell me your password"
SECURE-OK: Password
Convenience class providing a default implementation of
Consumer.Default implementation of
ExceptionHandler
used by AMQConnection.Default SASL configuration.
Encapsulates a group of parameters used for AMQP's Basic methods
Interface to an exception-handling object.
The EXTERNAL auth mechanism
Implement this interface in order to be notified of Channel.Flow
events.
An implementation of
ExceptionHandler that does not
close channels on unhandled consumer and listener exception.Represents an AMQP wire-protocol frame, with frame type, channel number, and payload bytes.
Interface to a frame handler.
Encapsulates the response from a
Channel.basicGet(java.lang.String, boolean) message-retrieval method call
- essentially a static bean "holder" with message response data.A class for allocating integers from a given range that uses a
BitSet representation of the free integers.Implementation of SaslConfig that uses the JDK SASL implementation.
Thrown when a JSON-RPC service indicates an error occurred during a call.
JSON-RPC Server class.
Interface for classes that wish to control their own serialization.
Utility methods for working with JSON objects in Java.
An object providing access to a LongString.
Utility for working with
LongStrings.Encapsulates a frame format error at the wire level.
Subclass of RpcServer which uses AMQP wire-format encoded tables as
requests and replies.
Constant holder class with useful static instances of
AMQContentHeader.Base class for AMQP method objects, specialized by autogenerated
code in AMQP.java.
Public interface to objects representing an AMQP method - see the spec for details.
Parses AMQP wire-protocol
Method arguments from a
DataInputStream.Generates AMQP wire-protocol encoded arguments.
Encapsulates an exception indicating that the connection has missed too many heartbeats
and is being shut down.
Deprecated.
Description of a single JSON-RPC procedure parameter.
The PLAIN auth mechanism
Thrown when the likely cause is an authentication failure.
Description of a single JSON-RPC procedure.
Thrown to indicate that the server does not support the wire protocol version
we requested immediately after opening the TCP socket.
Convenience class: an implementation of
Consumer with
straightforward blocking semantics.Encapsulates an arbitrary message - simple "bean" holder structure.
Not part of the public API.
Provides a way to register (network, AMQP 0-9-1) connection recovery
callbacks.
AMQConnection modification that uses RecoveryAwareChannelNChannelN modification that keeps track of delivery
tags and avoids sendingA RecoveryListener receives notifications about completed automatic connection
recovery.
Implement this interface in order to be notified of failed
deliveries when basicPublish is called with "mandatory" or
"immediate" flags set.
Convenience class which manages simple RPC-style communication.
Class which manages a request queue for a simple RPC-style service.
This interface represents a hook to allow you to control how exactly
a sasl client is selected during authentication.
Our own view of a SASL authentication mechanism, introduced to remove a
dependency on javax.security.sasl.
This interface exists as a workaround for the annoyingness of java.lang.Cloneable.
Description of a JSON-RPC service.
A generic queue-like implementation (supporting operations
addIfNotPresent,
poll, contains, and isEmpty)
which restricts a queue element to appear at most once.A ShutdownListener receives information about the shutdown of connections and
channels.
Interface for components that are shutdown capable and
that allow listeners to be added for shutdown signals
A class that manages
ShutdownListeners and remembers the reason for a shutdown.Encapsulates a shutdown condition for a connection to an AMQP broker.
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.
A socket-based frame handler.
An implementation of
ExceptionHandler that does
close channels on unhandled consumer exception.Subclass of RpcServer which accepts UTF-8 string requests.
Indicates an exception thrown during topology recovery.
AMQP Protocol Analyzer program.
Logging strings to an outputStream.
Utility stream: proxies another stream, making it appear to be no
longer than a preset limit.
Thrown when the command parser hits an unexpected frame type.
Indicates that a
Method object was supplied that was not
expected.Thrown when the protocol handlers detect an unknown class number or
method number.
Catch-all holder class for static helper methods.
Helper class to read AMQP wire-protocol encoded values.
Helper class to generate AMQP wire-protocol encoded values.
A clone of LinkedBlockingQueue
with the addition of a
VariableLinkedBlockingQueue.setCapacity(int) method, allowing us to
change the capacity of the queue while it is in use.Encapsulation of AMQP protocol version
This is a generic implementation of the
Channelsspecification in Channeling Work, Nov 2010 (channels.pdf).