All Classes Interface Summary Class Summary Enum Summary Exception Summary Error Summary
| Class |
Description |
| AbstractFrameHandlerFactory |
|
| AbstractMetricsCollector |
|
| 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.
|
| 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 |
|
| BlockedListener |
Implement this interface in order to be notified of connection block and
unblock events.
|
| BlockingCell<T> |
Simple one-shot IPC mechanism.
|
| BlockingQueueNioQueue |
|
| BlockingValueOrException<V,E extends Throwable & SensibleClone<E>> |
|
| BuiltinExchangeType |
Enum for built-in exchange types.
|
| ByteBufferFactory |
|
| ByteBufferOutputStream |
Bridge between the byte buffer and stream worlds.
|
| 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.
|
| ConfirmListener |
Implement this interface in order to be notified of Confirm events.
|
| Connection |
Public API: Interface to an AMQ connection.
|
| ConnectionContext |
The context of the freshly open TCP connection.
|
| ConnectionFactory |
Convenience "factory" class to facilitate opening a Connection to an AMQP broker. |
| ConnectionFactoryConfigurator |
|
| ConnectionParams |
|
| ConnectionPostProcessor |
Hook to add processing on the open TCP connection.
|
| ConnectionPostProcessors |
|
| ConnectionPostProcessors.AbstractConnectionPostProcessor |
|
| ConnectionPostProcessors.Builder |
|
| Consumer |
Interface for application callback objects to receive notifications and messages from
a queue by subscription.
|
| ConsumerCancelledException |
|
| ConsumerRecoveryListener |
Not part of the public API.
|
| ConsumerWorkService |
|
| ContentHeader |
Public API for abstract AMQP content header objects.
|
| ContentHeaderPropertyReader |
Parses an AMQP wire-protocol ContentHeader from a
DataInputStream. |
| ContentHeaderPropertyWriter |
|
| 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.
|
| DefaultByteBufferFactory |
|
| DefaultByteBufferFactory.ByteBufferAllocator |
|
| DefaultConsumer |
Convenience class providing a default implementation of Consumer. |
| DefaultCredentialsProvider |
Default implementation of a CredentialsProvider which simply holds a static
username and password.
|
| DefaultExceptionHandler |
|
| DefaultJsonRpcMapper |
Deprecated.
|
| DefaultRetryHandler |
Composable topology recovery retry handler.
|
| DefaultRetryHandler.RetryCondition<E extends RecordedEntity> |
|
| DefaultRetryHandler.RetryOperation<T> |
|
| DefaultSaslConfig |
Default SASL configuration.
|
| DefaultSocketChannelConfigurator |
|
| DefaultSocketConfigurator |
|
| DnsRecordIpAddressResolver |
|
| DnsSrvRecordAddressResolver |
|
| 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
|
| FlowListener |
Deprecated. |
| 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 |
|
| FrameHandler |
Interface to a frame handler.
|
| FrameHandlerFactory |
|
| FrameWriteRequest |
|
| GetResponse |
|
| HeaderWriteRequest |
|
| IntAllocator |
A class for allocating integers from a given range that uses a
BitSet representation of the free integers. |
| JacksonJsonRpcMapper |
|
| JDKSaslConfig |
Implementation of SaslConfig that uses the JDK SASL implementation.
|
| JSONReader |
Deprecated.
|
| 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.
|
| JSONUtil |
Utility methods for working with JSON objects in Java.
|
| JSONWriter |
Deprecated.
|
| ListAddressResolver |
|
| LogTrafficListener |
|
| LongString |
An object providing access to a LongString.
|
| LongStringHelper |
|
| 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 |
|
| 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.
|
| MicrometerMetricsCollector |
|
| MicrometerMetricsCollector.Metrics |
|
| MicrometerMetricsCollector.MetricsCreator |
|
| 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 |
|
| NioQueue |
Contract to exchange frame between application threads and NIO thread.
|
| NioQueueFactory |
|
| NoOpMetricsCollector |
|
| NullTrustManager |
Deprecated. |
| 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 |
Deprecated. |
| QueueingConsumer.Delivery |
Encapsulates an arbitrary message - simple "bean" holder structure.
|
| 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.
|
| RecoveryAwareAMQConnection |
|
| 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 |
|
| 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.
|
| 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.
|
| 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.CorrelationIdSupplier |
Contract to generate correlation IDs.
|
| RpcClient.Response |
The response object is an envelope that contains all of the data provided to the `handleDelivery` consumer
|
| RpcClient.RpcClientReplyHandler |
Behavior to handle RPC reply.
|
| RpcClientParams |
|
| 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.
|
| 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 |
|
| ShutdownSignalException |
Encapsulates a shutdown condition for a connection to an AMQP broker.
|
| SingleShotLinearTimer |
Deprecated. |
| SocketChannelConfigurator |
|
| SocketChannelConfigurators |
|
| SocketChannelConfigurators.AbstractSocketChannelConfigurator |
|
| SocketChannelConfigurators.Builder |
|
| SocketChannelFrameHandler |
|
| SocketChannelFrameHandlerFactory |
|
| SocketChannelFrameHandlerState |
|
| SocketChannelRegistration |
|
| SocketConfigurator |
|
| SocketConfigurators |
|
| SocketConfigurators.AbstractSocketConfigurator |
|
| SocketConfigurators.Builder |
|
| SocketFrameHandler |
A socket-based frame handler.
|
| SocketFrameHandlerFactory |
|
| SslEngineByteBufferOutputStream |
Bridge between the byte buffer and stream worlds.
|
| SslEngineConfigurator |
|
| SslEngineConfigurators |
|
| SslEngineConfigurators.AbstractSslEngineConfigurator |
|
| SslEngineConfigurators.Builder |
|
| SslEngineFrameBuilder |
Sub-class of FrameBuilder that unwraps crypted data from the network. |
| SslEngineHelper |
|
| StandardMetricsCollector |
|
| 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 |
|
| TopologyRecoveryRetryLogic |
|
| 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 |
|
| 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.
|
| UnroutableRpcRequestException |
Exception thrown when a RPC request isn't routed to any queue.
|
| 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.
|
| VariableLinkedBlockingQueue<E> |
|
| 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 |
|