All Classes

Class	Description
AbstractFrameHandlerFactory
AbstractMetricsCollector	Base class for MetricsCollector.
AbstractMetricsCollector.ChannelState
AbstractMetricsCollector.ConnectionState
Address	A representation of network addresses, i.e.
AddressResolver	Strategy interface to get the potential servers to connect to.
AlreadyClosedException	Thrown when application tries to perform an action on connection/channel which was already closed
AMQBasicProperties
AMQChannel	Base class modelling an AMQ channel.
AMQChannel.BlockingRpcContinuation<T>
AMQChannel.RpcContinuation
AMQChannel.SimpleBlockingRpcContinuation
AMQCommand	AMQP 0-9-1-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.
AMQConnection.DefaultConnectionInfo
AMQContentHeader	Implementation of ContentHeader - specialized by autogenerated code in AMQP.java.
AMQImpl
AMQImpl.Access
AMQImpl.Access.Request
AMQImpl.Access.RequestOk
AMQImpl.Basic
AMQImpl.Basic.Ack
AMQImpl.Basic.Cancel
AMQImpl.Basic.CancelOk
AMQImpl.Basic.Consume
AMQImpl.Basic.ConsumeOk
AMQImpl.Basic.Deliver
AMQImpl.Basic.Get
AMQImpl.Basic.GetEmpty
AMQImpl.Basic.GetOk
AMQImpl.Basic.Nack
AMQImpl.Basic.Publish
AMQImpl.Basic.Qos
AMQImpl.Basic.QosOk
AMQImpl.Basic.Recover
AMQImpl.Basic.RecoverAsync
AMQImpl.Basic.RecoverOk
AMQImpl.Basic.Reject
AMQImpl.Basic.Return
AMQImpl.Channel
AMQImpl.Channel.Close
AMQImpl.Channel.CloseOk
AMQImpl.Channel.Flow
AMQImpl.Channel.FlowOk
AMQImpl.Channel.Open
AMQImpl.Channel.OpenOk
AMQImpl.Confirm
AMQImpl.Confirm.Select
AMQImpl.Confirm.SelectOk
AMQImpl.Connection
AMQImpl.Connection.Blocked
AMQImpl.Connection.Close
AMQImpl.Connection.CloseOk
AMQImpl.Connection.Open
AMQImpl.Connection.OpenOk
AMQImpl.Connection.Secure
AMQImpl.Connection.SecureOk
AMQImpl.Connection.Start
AMQImpl.Connection.StartOk
AMQImpl.Connection.Tune
AMQImpl.Connection.TuneOk
AMQImpl.Connection.Unblocked
AMQImpl.Connection.UpdateSecret
AMQImpl.Connection.UpdateSecretOk
AMQImpl.DefaultMethodVisitor
AMQImpl.Exchange
AMQImpl.Exchange.Bind
AMQImpl.Exchange.BindOk
AMQImpl.Exchange.Declare
AMQImpl.Exchange.DeclareOk
AMQImpl.Exchange.Delete
AMQImpl.Exchange.DeleteOk
AMQImpl.Exchange.Unbind
AMQImpl.Exchange.UnbindOk
AMQImpl.MethodVisitor
AMQImpl.Queue
AMQImpl.Queue.Bind
AMQImpl.Queue.BindOk
AMQImpl.Queue.Declare
AMQImpl.Queue.DeclareOk
AMQImpl.Queue.Delete
AMQImpl.Queue.DeleteOk
AMQImpl.Queue.Purge
AMQImpl.Queue.PurgeOk
AMQImpl.Queue.Unbind
AMQImpl.Queue.UnbindOk
AMQImpl.Tx
AMQImpl.Tx.Commit
AMQImpl.Tx.CommitOk
AMQImpl.Tx.Rollback
AMQImpl.Tx.RollbackOk
AMQImpl.Tx.Select
AMQImpl.Tx.SelectOk
AMQP
AMQP.Access
AMQP.Access.Request
AMQP.Access.Request.Builder
AMQP.Access.RequestOk
AMQP.Access.RequestOk.Builder
AMQP.Basic
AMQP.Basic.Ack
AMQP.Basic.Ack.Builder
AMQP.Basic.Cancel
AMQP.Basic.Cancel.Builder
AMQP.Basic.CancelOk
AMQP.Basic.CancelOk.Builder
AMQP.Basic.Consume
AMQP.Basic.Consume.Builder
AMQP.Basic.ConsumeOk
AMQP.Basic.ConsumeOk.Builder
AMQP.Basic.Deliver
AMQP.Basic.Deliver.Builder
AMQP.Basic.Get
AMQP.Basic.Get.Builder
AMQP.Basic.GetEmpty
AMQP.Basic.GetEmpty.Builder
AMQP.Basic.GetOk
AMQP.Basic.GetOk.Builder
AMQP.Basic.Nack
AMQP.Basic.Nack.Builder
AMQP.Basic.Publish
AMQP.Basic.Publish.Builder
AMQP.Basic.Qos
AMQP.Basic.Qos.Builder
AMQP.Basic.QosOk
AMQP.Basic.QosOk.Builder
AMQP.Basic.Recover
AMQP.Basic.Recover.Builder
AMQP.Basic.RecoverAsync
AMQP.Basic.RecoverAsync.Builder
AMQP.Basic.RecoverOk
AMQP.Basic.RecoverOk.Builder
AMQP.Basic.Reject
AMQP.Basic.Reject.Builder
AMQP.Basic.Return
AMQP.Basic.Return.Builder
AMQP.BasicProperties
AMQP.BasicProperties.Builder
AMQP.Channel
AMQP.Channel.Close
AMQP.Channel.Close.Builder
AMQP.Channel.CloseOk
AMQP.Channel.CloseOk.Builder
AMQP.Channel.Flow
AMQP.Channel.Flow.Builder
AMQP.Channel.FlowOk
AMQP.Channel.FlowOk.Builder
AMQP.Channel.Open
AMQP.Channel.Open.Builder
AMQP.Channel.OpenOk
AMQP.Channel.OpenOk.Builder
AMQP.Confirm
AMQP.Confirm.Select
AMQP.Confirm.Select.Builder
AMQP.Confirm.SelectOk
AMQP.Confirm.SelectOk.Builder
AMQP.Connection
AMQP.Connection.Blocked
AMQP.Connection.Blocked.Builder
AMQP.Connection.Close
AMQP.Connection.Close.Builder
AMQP.Connection.CloseOk
AMQP.Connection.CloseOk.Builder
AMQP.Connection.Open
AMQP.Connection.Open.Builder
AMQP.Connection.OpenOk
AMQP.Connection.OpenOk.Builder
AMQP.Connection.Secure
AMQP.Connection.Secure.Builder
AMQP.Connection.SecureOk
AMQP.Connection.SecureOk.Builder
AMQP.Connection.Start
AMQP.Connection.Start.Builder
AMQP.Connection.StartOk
AMQP.Connection.StartOk.Builder
AMQP.Connection.Tune
AMQP.Connection.Tune.Builder
AMQP.Connection.TuneOk
AMQP.Connection.TuneOk.Builder
AMQP.Connection.Unblocked
AMQP.Connection.Unblocked.Builder
AMQP.Connection.UpdateSecret
AMQP.Connection.UpdateSecret.Builder
AMQP.Connection.UpdateSecretOk
AMQP.Connection.UpdateSecretOk.Builder
AMQP.Exchange
AMQP.Exchange.Bind
AMQP.Exchange.Bind.Builder
AMQP.Exchange.BindOk
AMQP.Exchange.BindOk.Builder
AMQP.Exchange.Declare
AMQP.Exchange.Declare.Builder
AMQP.Exchange.DeclareOk
AMQP.Exchange.DeclareOk.Builder
AMQP.Exchange.Delete
AMQP.Exchange.Delete.Builder
AMQP.Exchange.DeleteOk
AMQP.Exchange.DeleteOk.Builder
AMQP.Exchange.Unbind
AMQP.Exchange.Unbind.Builder
AMQP.Exchange.UnbindOk
AMQP.Exchange.UnbindOk.Builder
AMQP.PROTOCOL
AMQP.Queue
AMQP.Queue.Bind
AMQP.Queue.Bind.Builder
AMQP.Queue.BindOk
AMQP.Queue.BindOk.Builder
AMQP.Queue.Declare
AMQP.Queue.Declare.Builder
AMQP.Queue.DeclareOk
AMQP.Queue.DeclareOk.Builder
AMQP.Queue.Delete
AMQP.Queue.Delete.Builder
AMQP.Queue.DeleteOk
AMQP.Queue.DeleteOk.Builder
AMQP.Queue.Purge
AMQP.Queue.Purge.Builder
AMQP.Queue.PurgeOk
AMQP.Queue.PurgeOk.Builder
AMQP.Queue.Unbind
AMQP.Queue.Unbind.Builder
AMQP.Queue.UnbindOk
AMQP.Queue.UnbindOk.Builder
AMQP.Tx
AMQP.Tx.Commit
AMQP.Tx.Commit.Builder
AMQP.Tx.CommitOk
AMQP.Tx.CommitOk.Builder
AMQP.Tx.Rollback
AMQP.Tx.Rollback.Builder
AMQP.Tx.RollbackOk
AMQP.Tx.RollbackOk.Builder
AMQP.Tx.Select
AMQP.Tx.Select.Builder
AMQP.Tx.SelectOk
AMQP.Tx.SelectOk.Builder
AuthenticationFailureException	Thrown when the broker refuses access due to an authentication failure.
AutorecoveringChannel	Channel implementation that is automatically recovered during connection recovery.
AutorecoveringConnection	Connection implementation that performs automatic recovery when connection shutdown is not initiated by the application (e.g.
BackoffPolicy	Backoff policy for topology recovery retry attempts.
BasicProperties
BlockedCallback	Implement this interface in order to be notified of connection block events.
BlockedListener	Implement this interface in order to be notified of connection block and unblock events.
BlockingCell<T>	Simple one-shot IPC mechanism.
BlockingQueueNioQueue	Bridge between NioQueue and JDK's BlockingQueue.
BlockingValueOrException<V,E extends java.lang.Throwable & SensibleClone<E>>
BuiltinExchangeType	Enum for built-in exchange types.
ByteBufferFactory	Contract to create ByteBuffers.
ByteBufferOutputStream	Bridge between the byte buffer and stream worlds.
CancelCallback	Callback interface to be notified of the cancellation of a consumer.
Channel	Interface to a channel.
ChannelContinuationTimeoutException	Exception thrown when a channel times out on a continuation during a RPC call.
ChannelManager	Manages a set of channels, indexed by channel number (1.._channelMax).
ChannelN	Main interface to AMQP protocol functionality.
ClientVersion	Publicly available Client Version information
Command	Interface to a container for an AMQP method-and-arguments, with optional content header and body.
CommandAssembler	Class responsible for piecing together a command from a series of Frames.
CommandAssembler.CAState	Current state, used to decide how to handle each incoming frame.
CompletableFutureRpcWrapper
ConfirmCallback	Implement this interface in order to be notified of Confirm events.
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 a RabbitMQ node.
ConnectionFactoryConfigurator	Helper class to load ConnectionFactory settings from a property file.
ConnectionParams
Consumer	Interface for application callback objects to receive notifications and messages from a queue by subscription.
ConsumerCancelledException
ConsumerDispatcher	Dispatches notifications to a Consumer on an internally-managed executor service and work pool.
ConsumerRecoveryListener	Not part of the public API.
ConsumerShutdownSignalCallback	Callback interface to be notified when either the consumer channel or the underlying connection has been shut down.
ConsumerWorkService
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.
Copyright
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
CredentialsProvider	Provider interface for establishing credentials for connecting to the broker.
CredentialsRefreshService	Provider interface to refresh credentials when appropriate and perform an operation once the credentials have been renewed.
DefaultByteBufferFactory	Default ByteBufferFactory that creates heap-based ByteBuffers.
DefaultConsumer	Convenience class providing a default implementation of Consumer.
DefaultCredentialsProvider	Default implementation of a CredentialsProvider which simply holds a static username and password.
DefaultCredentialsRefreshService	Scheduling-based implementation of CredentialsRefreshService.
DefaultCredentialsRefreshService.CredentialsProviderState	State and refresh behavior for a CredentialsProvider and its registered entities.
DefaultCredentialsRefreshService.DefaultCredentialsRefreshServiceBuilder	Builder to create instances of DefaultCredentialsRefreshService.DefaultCredentialsRefreshServiceBuilder.
DefaultCredentialsRefreshService.FixedDelayBeforeExpirationRefreshDelayStrategy
DefaultCredentialsRefreshService.FixedTimeApproachingExpirationStrategy
DefaultCredentialsRefreshService.RatioRefreshDelayStrategy
DefaultCredentialsRefreshService.Registration
DefaultExceptionHandler	Default implementation of ExceptionHandler used by AMQConnection.
DefaultJsonRpcMapper	Deprecated. use JacksonJsonRpcMapper instead
DefaultRetryHandler	Composable topology recovery retry handler.
DefaultRetryHandler.RetryOperation<T>
DefaultSaslConfig	Default SASL configuration.
DefaultSocketChannelConfigurator
DefaultSocketConfigurator
DeliverCallback	Callback interface to be notified when a message is delivered.
Delivery	Encapsulates an arbitrary message - simple "bean" holder structure.
DnsRecordIpAddressResolver	AddressResolver that resolves DNS record IPs.
DnsSrvRecordAddressResolver	AddressResolver that resolves addresses against a DNS SRV request.
DnsSrvRecordAddressResolver.SrvRecord
Envelope	Encapsulates a group of parameters used for AMQP's Basic methods
Environment	Infers information about the execution environment, e.g.
ErrorOnWriteListener	Listener called when a connection gets an IO error trying to write on the socket.
ExceptionHandler	Interface to an exception-handling object.
ExternalMechanism	The EXTERNAL auth mechanism
ForgivingExceptionHandler	An implementation of ExceptionHandler that does not close channels on unhandled consumer and listener exception.
Frame	Represents an AMQP wire-protocol frame, with frame type, channel number, and payload bytes.
FrameBuilder	Class to create AMQP frames from a ReadableByteChannel.
FrameHandler	Interface to a frame handler.
FrameHandlerFactory
FrameWriteRequest
GetResponse	Encapsulates the response from a Channel.basicGet(java.lang.String, boolean) message-retrieval method call - essentially a static bean "holder" with message response data.
HeaderWriteRequest
HeartbeatSender	Manages heartbeat sending for a AMQConnection.
IntAllocator	A class for allocating integers from a given range that uses a BitSet representation of the free integers.
JacksonJsonRpcMapper	JsonRpcMapper based on Jackson.
JDKSaslConfig	Implementation of SaslConfig that uses the JDK SASL implementation.
JSONReader	Deprecated. Use a third-party JSON library, e.g.
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.
JsonRpcMapper	Abstraction to handle JSON parsing and generation.
JsonRpcMapper.JsonRpcRequest
JsonRpcMapper.JsonRpcResponse
JsonRpcMappingException
JsonRpcServer	JSON-RPC Server class.
JSONSerializable	Deprecated. Use a third-party JSON library, e.g.
JSONUtil	Utility methods for working with JSON objects in Java.
JSONWriter	Deprecated. Use a third-party JSON library, e.g.
ListAddressResolver	Simple implementation of AddressResolver that returns a fixed list.
LogTrafficListener	TrafficListener that logs Command at TRACE level.
LongString	An object providing access to a LongString.
LongStringHelper	Utility for working with LongStrings.
LongStringHelper.ByteArrayLongString	Private API - Implementation of LongString.
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	Base class for AMQP method objects, specialized by autogenerated code in AMQP.java.
Method	Public interface to objects representing an AMQP 0-9-1 method
MethodArgumentReader	Parses AMQP wire-protocol Method arguments from a DataInputStream.
MethodArgumentWriter	Generates AMQP wire-protocol encoded arguments.
MetricsCollector	Interface to gather execution data of the client.
MissedHeartbeatException	Encapsulates an exception indicating that the connection has missed too many heartbeats and is being shut down.
NetworkConnection
NioContext	Context when creating resources for a NIO-based connection.
NioHelper
NioLoop	Logic of the NIO loop.
NioLoopContext
NioParams	Parameters used to configure the NIO mode of a ConnectionFactory.
NioQueue	Contract to exchange frame between application threads and NIO thread.
NoOpMetricsCollector
NoOpObservationCollector
OAuth2ClientCredentialsGrantCredentialsProvider	A CredentialsProvider that performs an OAuth 2 Client Credentials flow to retrieve a token.
OAuth2ClientCredentialsGrantCredentialsProvider.JacksonTokenLookup
OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder	Helper to create OAuth2ClientCredentialsGrantCredentialsProvider instances.
OAuth2ClientCredentialsGrantCredentialsProvider.TlsConfiguration	TLS configuration for a OAuth2ClientCredentialsGrantCredentialsProvider.
OAuth2ClientCredentialsGrantCredentialsProvider.Token
OAuthTokenManagementException
ObservationCollector	API to instrument operations in the AMQP client.
ObservationCollector.BasicGetCall	Underlying basic.get call.
ObservationCollector.ConnectionInfo	Connection information.
ObservationCollector.PublishCall	Underlying publishing call.
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.
QueueRecoveryListener	Not part of the public API.
RecordedBinding
RecordedConsumer
RecordedEntity
RecordedExchange
RecordedExchangeBinding
RecordedNamedEntity
RecordedQueue
RecordedQueueBinding
Recoverable	Provides a way to register (network, AMQP 0-9-1) connection recovery callbacks.
RecoverableChannel	Convenient interface when working against auto-recovery channels.
RecoverableConnection	Convenient interface when working against auto-recovery connections.
RecoveredQueueNameSupplier	Functional callback interface that can be used to rename a queue during topology recovery.
RecoveryAwareAMQConnection	AMQConnection modification that uses RecoveryAwareChannelN
RecoveryAwareAMQConnectionFactory
RecoveryAwareChannelManager
RecoveryAwareChannelN	ChannelN modification that keeps track of delivery tags and avoids sending
RecoveryCanBeginListener	Used internally to indicate when connection recovery can begin.
RecoveryDelayHandler	A RecoveryDelayHandler is used to tell automatic recovery how long to sleep between reconnect attempts.
RecoveryDelayHandler.DefaultRecoveryDelayHandler	Basic implementation of RecoveryDelayHandler that returns the network recovery interval each time.
RecoveryDelayHandler.ExponentialBackoffDelayHandler	Backoff implementation of RecoveryDelayHandler that uses the Fibonacci sequence (by default) to increase the recovery delay time after each failed attempt.
RecoveryListener	A RecoveryListener receives notifications about completed automatic connection recovery.
RefreshProtectedCredentialsProvider<T>	An abstract CredentialsProvider that does not let token refresh happen concurrently.
ResolvedInetAddress
RetryContext	The context of a topology recovery retry operation.
RetryHandler	Contract to retry failed operations during topology recovery.
RetryResult	The retry of a retried topology recovery operation.
Return
ReturnCallback	Implement this interface in order to be notified of failed deliveries when basicPublish is called with "mandatory" or "immediate" flags set.
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 simple RPC-style communication.
RpcClient.IncrementingCorrelationIdSupplier
RpcClient.Response	The response object is an envelope that contains all of the data provided to the `handleDelivery` consumer
RpcClientParams	Holder class to configure a RpcClient.
RpcContinuationRpcWrapper
RpcServer	Class which manages a request queue for a simple RPC-style service.
RpcServer.DefaultRpcConsumer
RpcServer.RpcConsumer
RpcWrapper
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.
SelectorHolder
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	A ShutdownListener receives information about the shutdown of connections and channels.
ShutdownNotifier	Interface for components that are shutdown capable and that allow listeners to be added for shutdown signals
ShutdownNotifierComponent	A class that manages ShutdownListeners and remembers the reason for a shutdown.
ShutdownSignalException	Encapsulates a shutdown condition for a connection to an AMQP broker.
SocketChannelConfigurator
SocketChannelConfigurators	Ready-to-use instances and builder for SocketChannelConfigurator.
SocketChannelConfigurators.Builder
SocketChannelFrameHandler
SocketChannelFrameHandlerFactory
SocketChannelFrameHandlerState
SocketChannelRegistration
SocketConfigurator
SocketConfigurators	Ready-to-use instances and builder for SocketConfigurator.
SocketConfigurators.Builder
SocketFrameHandler	A socket-based frame handler.
SocketFrameHandlerFactory
SslContextFactory	A factory to create SSLContexts.
SslEngineByteBufferOutputStream	Bridge between the byte buffer and stream worlds.
SslEngineConfigurator
SslEngineConfigurators	Ready-to-use instances and builder for SslEngineConfigurators.
SslEngineConfigurators.Builder
SslEngineFrameBuilder	Sub-class of FrameBuilder that unwraps crypted data from the network.
SslEngineHelper
StrictExceptionHandler	An implementation of ExceptionHandler that does close channels on unhandled consumer exception.
StringRpcServer	Subclass of RpcServer which accepts UTF-8 string requests.
TlsUtils	Utility to extract information from X509 certificates.
TopologyRecoveryException	Indicates an exception thrown during topology recovery.
TopologyRecoveryFilter	Filter to know whether entities should be recovered or not.
TopologyRecoveryRetryHandlerBuilder	Builder to ease creation of DefaultRetryHandler instances.
TopologyRecoveryRetryLogic	Useful ready-to-use conditions and operations for DefaultRetryHandler.
TrafficListener	Contract to log outbound and inbound Commands.
TruncatedInputStream	Utility stream: proxies another stream, making it appear to be no longer than a preset limit.
TrustEverythingTrustManager	Convenience class providing a default implementation of X509TrustManager.
UnblockedCallback	Implement this interface in order to be notified of connection unblock events.
UnexpectedFrameError	Thrown when the command parser hits an unexpected frame type.
UnexpectedMethodError	Indicates that a Method object was supplied that was not expected.
UnknownChannelException
UnknownClassOrMethodId	Thrown when the protocol handlers detect an unknown class number or method number.
UnroutableRpcRequestException	Exception thrown when a RPC request isn't routed to any queue.
UpdateSecretExtension	Helper for update-secret extension Method.
UpdateSecretExtension.UpdateSecret
Utility	Catch-all holder class for static helper methods.
Utility.ThrowableCreatedElsewhere
Utils
Utils
Utils.IoTimeoutExceptionRunnable
ValueOrException<V,E extends java.lang.Throwable & SensibleClone<E>>
ValueReader	Helper class to read AMQP wire-protocol encoded values.
ValueWriter	Helper class to generate AMQP wire-protocol encoded values.
VariableLinkedBlockingQueue<E>	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.
VariableLinkedBlockingQueue.Node<E>	Linked list node class
Version	Encapsulation of AMQP protocol version
WorkPool<K,W>	This is a generic implementation of the channels specification in Channeling Work, Nov 2010 (channels.pdf).
WorkPoolFullException	Exception thrown when WorkPool enqueueing times out.
WriteRequest