Package com.rabbitmq.client.impl

Implementations of interfaces specified in the client API, and their supporting classes.

See:
          Description

Interface Summary
AMQChannel.RpcContinuation  
AMQImpl.MethodVisitor  
ExceptionHandler Interface to an exception-handling object.
FrameHandler Interface to a frame handler.
 

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  
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  
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).
 

Package com.rabbitmq.client.impl Description

Implementations of interfaces specified in the client API, and their supporting classes.