| AbstractFrameHandlerFactory |
|
| AbstractMetricsCollector |
|
| AMQBasicProperties |
|
| AMQChannel |
Base class modelling an AMQ channel.
|
| AMQChannel.BlockingRpcContinuation<T> |
|
| 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.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 |
|
| 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
|
| CompletableFutureRpcWrapper |
|
| ConnectionParams |
|
| ConsumerWorkService |
|
| 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 |
|
| DefaultCredentialsProvider |
Default implementation of a CredentialsProvider which simply holds a static
username and password.
|
| DefaultCredentialsRefreshService |
|
| DefaultCredentialsRefreshService.DefaultCredentialsRefreshServiceBuilder |
|
| DefaultExceptionHandler |
|
| Environment |
Infers information about the execution environment, e.g.
|
| 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.
|
| LogTrafficListener |
|
| LongStringHelper |
|
| 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.
|
| MicrometerMetricsCollector |
|
| OAuth2ClientCredentialsGrantCredentialsProvider |
|
| OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder |
|
| OAuth2ClientCredentialsGrantCredentialsProvider.TlsConfiguration |
|
| OAuth2ClientCredentialsGrantCredentialsProvider.Token |
|
| PlainMechanism |
The PLAIN auth mechanism
|
| RefreshProtectedCredentialsProvider<T> |
|
| RpcContinuationRpcWrapper |
|
| SetQueue<T> |
A generic queue-like implementation (supporting operations addIfNotPresent,
poll, contains, and isEmpty)
which restricts a queue element to appear at most once.
|
| ShutdownNotifierComponent |
|
| SocketFrameHandler |
A socket-based frame handler.
|
| SocketFrameHandlerFactory |
|
| StandardMetricsCollector |
|
| StrictExceptionHandler |
An implementation of ExceptionHandler that does
close channels on unhandled consumer exception. |
| TlsUtils |
Utility to extract information from X509 certificates.
|
| TruncatedInputStream |
Utility stream: proxies another stream, making it appear to be no
longer than a preset limit.
|
| 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).
|