|
Class Summary |
| AMQBasicProperties |
|
| AMQChannel |
Base class modelling an AMQ channel. |
| AMQChannel.BlockingRpcContinuation<T> |
|
| AMQChannel.SimpleBlockingRpcContinuation |
|
| AMQCommand |
AMQ-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.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.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 |
| ContentHeaderPropertyReader |
Parses an AMQP wire-protocol ContentHeader from a
DataInputStream. |
| ContentHeaderPropertyWriter |
Generates an AMQP wire-protocol packet from a ContentHeader. |
| 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 |
|
| DefaultExceptionHandler |
Default implementation of ExceptionHandler used by AMQConnection. |
| ExternalMechanism |
The EXTERNAL auth mechanism |
| Frame |
Represents an AMQP wire-protocol frame, with frame type, channel number, and payload bytes. |
| LongStringHelper |
Utility for working with LongStrings. |
| 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. |
| PlainMechanism |
The PLAIN auth mechanism |
| 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 |
A class that manages ShutdownListeners and remembers the reason for a shutdown. |
| SocketFrameHandler |
A socket-based frame handler. |
| 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. |
| 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). |
Implementations of interfaces specified in the client API, and their supporting classes.