| AbstractFrameHandlerFactory |
|
| AbstractMetricsCollector |
|
| AMQChannel |
Base class modelling an AMQ channel.
|
| AMQChannel.BlockingRpcContinuation |
|
| AMQChannel.RpcContinuation |
|
| 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.Access.Request |
|
| AMQImpl.Access.RequestOk |
|
| 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.Close |
|
| AMQImpl.Channel.CloseOk |
|
| AMQImpl.Channel.Flow |
|
| AMQImpl.Channel.FlowOk |
|
| AMQImpl.Channel.Open |
|
| AMQImpl.Channel.OpenOk |
|
| AMQImpl.Confirm.Select |
|
| AMQImpl.Confirm.SelectOk |
|
| 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.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.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.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.
|
| ConnectionParams |
|
| ConsumerWorkService |
|
| ContentHeaderPropertyWriter |
|
| CredentialsProvider |
Provider interface for establishing credentials for connecting to the broker.
|
| ErrorOnWriteListener |
Listener called when a connection gets an IO error trying to write on the socket.
|
| 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.
|
| FrameHandler |
Interface to a frame handler.
|
| FrameHandlerFactory |
|
| 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.Metrics |
|
| MicrometerMetricsCollector.MetricsCreator |
|
| NetworkConnection |
|
| ShutdownNotifierComponent |
|
| StrictExceptionHandler |
An implementation of ExceptionHandler that does
close channels on unhandled consumer exception. |
| 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
|