Package com.rabbitmq.client

The client API proper: classes and interfaces representing the AMQP connections, channels, and wire-protocol framing descriptors.

See:
          Description

Interface Summary
AMQP  
AMQP.Access.Request  
AMQP.Access.RequestOk  
AMQP.Basic.Ack  
AMQP.Basic.Cancel  
AMQP.Basic.CancelOk  
AMQP.Basic.Consume  
AMQP.Basic.ConsumeOk  
AMQP.Basic.Deliver  
AMQP.Basic.Get  
AMQP.Basic.GetEmpty  
AMQP.Basic.GetOk  
AMQP.Basic.Nack  
AMQP.Basic.Publish  
AMQP.Basic.Qos  
AMQP.Basic.QosOk  
AMQP.Basic.Recover  
AMQP.Basic.RecoverAsync  
AMQP.Basic.RecoverOk  
AMQP.Basic.Reject  
AMQP.Basic.Return  
AMQP.Channel.Close  
AMQP.Channel.CloseOk  
AMQP.Channel.Flow  
AMQP.Channel.FlowOk  
AMQP.Channel.Open  
AMQP.Channel.OpenOk  
AMQP.Confirm.Select  
AMQP.Confirm.SelectOk  
AMQP.Connection.Close  
AMQP.Connection.CloseOk  
AMQP.Connection.Open  
AMQP.Connection.OpenOk  
AMQP.Connection.Secure  
AMQP.Connection.SecureOk  
AMQP.Connection.Start  
AMQP.Connection.StartOk  
AMQP.Connection.Tune  
AMQP.Connection.TuneOk  
AMQP.Exchange.Bind  
AMQP.Exchange.BindOk  
AMQP.Exchange.Declare  
AMQP.Exchange.DeclareOk  
AMQP.Exchange.Delete  
AMQP.Exchange.DeleteOk  
AMQP.Exchange.Unbind  
AMQP.Exchange.UnbindOk  
AMQP.Queue.Bind  
AMQP.Queue.BindOk  
AMQP.Queue.Declare  
AMQP.Queue.DeclareOk  
AMQP.Queue.Delete  
AMQP.Queue.DeleteOk  
AMQP.Queue.Purge  
AMQP.Queue.PurgeOk  
AMQP.Queue.Unbind  
AMQP.Queue.UnbindOk  
AMQP.Tx.Commit  
AMQP.Tx.CommitOk  
AMQP.Tx.Rollback  
AMQP.Tx.RollbackOk  
AMQP.Tx.Select  
AMQP.Tx.SelectOk  
BasicProperties  
Channel Public API: Interface to an AMQ channel.
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.
Consumer Interface for application callback objects to receive notifications and messages from a queue by subscription.
ContentHeader Public API for abstract AMQP content header objects.
FlowListener Implement this interface in order to be notified of Channel.Flow events.
LongString An object providing access to a LongString.
Method Public interface to objects representing an AMQP method - see the spec for details.
ReturnListener Implement this interface in order to be notified of failed deliveries when basicPublish is called with "mandatory" or "immediate" flags set.
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.
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
 

Class Summary
Address A representation of network addresses, i.e.
AMQP.Access  
AMQP.Access.Request.Builder  
AMQP.Access.RequestOk.Builder  
AMQP.Basic  
AMQP.Basic.Ack.Builder  
AMQP.Basic.Cancel.Builder  
AMQP.Basic.CancelOk.Builder  
AMQP.Basic.Consume.Builder  
AMQP.Basic.ConsumeOk.Builder  
AMQP.Basic.Deliver.Builder  
AMQP.Basic.Get.Builder  
AMQP.Basic.GetEmpty.Builder  
AMQP.Basic.GetOk.Builder  
AMQP.Basic.Nack.Builder  
AMQP.Basic.Publish.Builder  
AMQP.Basic.Qos.Builder  
AMQP.Basic.QosOk.Builder  
AMQP.Basic.Recover.Builder  
AMQP.Basic.RecoverAsync.Builder  
AMQP.Basic.RecoverOk.Builder  
AMQP.Basic.Reject.Builder  
AMQP.Basic.Return.Builder  
AMQP.BasicProperties  
AMQP.BasicProperties.Builder  
AMQP.Channel  
AMQP.Channel.Close.Builder  
AMQP.Channel.CloseOk.Builder  
AMQP.Channel.Flow.Builder  
AMQP.Channel.FlowOk.Builder  
AMQP.Channel.Open.Builder  
AMQP.Channel.OpenOk.Builder  
AMQP.Confirm  
AMQP.Confirm.Select.Builder  
AMQP.Confirm.SelectOk.Builder  
AMQP.Connection  
AMQP.Connection.Close.Builder  
AMQP.Connection.CloseOk.Builder  
AMQP.Connection.Open.Builder  
AMQP.Connection.OpenOk.Builder  
AMQP.Connection.Secure.Builder  
AMQP.Connection.SecureOk.Builder  
AMQP.Connection.Start.Builder  
AMQP.Connection.StartOk.Builder  
AMQP.Connection.Tune.Builder  
AMQP.Connection.TuneOk.Builder  
AMQP.Exchange  
AMQP.Exchange.Bind.Builder  
AMQP.Exchange.BindOk.Builder  
AMQP.Exchange.Declare.Builder  
AMQP.Exchange.DeclareOk.Builder  
AMQP.Exchange.Delete.Builder  
AMQP.Exchange.DeleteOk.Builder  
AMQP.Exchange.Unbind.Builder  
AMQP.Exchange.UnbindOk.Builder  
AMQP.PROTOCOL  
AMQP.Queue  
AMQP.Queue.Bind.Builder  
AMQP.Queue.BindOk.Builder  
AMQP.Queue.Declare.Builder  
AMQP.Queue.DeclareOk.Builder  
AMQP.Queue.Delete.Builder  
AMQP.Queue.DeleteOk.Builder  
AMQP.Queue.Purge.Builder  
AMQP.Queue.PurgeOk.Builder  
AMQP.Queue.Unbind.Builder  
AMQP.Queue.UnbindOk.Builder  
AMQP.Tx  
AMQP.Tx.Commit.Builder  
AMQP.Tx.CommitOk.Builder  
AMQP.Tx.Rollback.Builder  
AMQP.Tx.RollbackOk.Builder  
AMQP.Tx.Select.Builder  
AMQP.Tx.SelectOk.Builder  
ConnectionFactory Convenience "factory" class to facilitate opening a Connection to an AMQP broker.
DefaultConsumer Convenience class providing a default implementation of Consumer.
DefaultSaslConfig Default SASL configuration.
Envelope Encapsulates a group of parameters used for AMQP's Basic methods
GetResponse Encapsulates the response from a Channel.basicGet(java.lang.String, boolean) message-retrieval method call - essentially a static bean "holder" with message response data.
JDKSaslConfig Implementation of SaslConfig that uses the JDK SASL implementation.
MapRpcServer Subclass of RpcServer which uses AMQP wire-format encoded tables as requests and replies.
MessageProperties Constant holder class with useful static instances of AMQContentHeader.
NullTrustManager Convenience class providing a default implementation of javax.net.ssl.X509TrustManager.
QueueingConsumer Convenience class: an implementation of Consumer with straightforward blocking semantics.
QueueingConsumer.Delivery Encapsulates an arbitrary message - simple "bean" holder structure.
RpcClient Convenience class which manages a temporary reply queue for simple RPC-style communication.
RpcServer Class which manages a request queue for a simple RPC-style service.
StringRpcServer Subclass of RpcServer which accepts UTF-8 string requests.
 

Exception Summary
AlreadyClosedException Thrown when application tries to perform an action on connection/channel which was already closed
ConsumerCancelledException  
MalformedFrameException Encapsulates a frame format error at the wire level.
MissedHeartbeatException Encapsulates an exception indicating that the connection has missed too many heartbeats and is being shut down.
PossibleAuthenticationFailureException Thrown when the likely cause is an authentication failure.
ProtocolVersionMismatchException Thrown to indicate that the server does not support the wire protocol version we requested immediately after opening the TCP socket.
ShutdownSignalException Encapsulates a shutdown condition for a connection to an AMQP broker.
UnknownClassOrMethodId Thrown when the protocol handlers detect an unknown class number or method number.
 

Error Summary
UnexpectedFrameError Thrown when the command parser hits an unexpected frame type.
UnexpectedMethodError Indicates that a Method object was supplied that was not expected.
 

Package com.rabbitmq.client Description

The client API proper: classes and interfaces representing the AMQP connections, channels, and wire-protocol framing descriptors.