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	request an access ticket.
AMQP.Access.RequestOk	grant access to server resources.
AMQP.Basic.Ack	acknowledge one or more messages.
AMQP.Basic.Cancel	end a queue consumer.
AMQP.Basic.CancelOk	confirm a cancelled consumer.
AMQP.Basic.Consume	start a queue consumer.
AMQP.Basic.ConsumeOk	confirm a new consumer.
AMQP.Basic.Deliver	notify the client of a consumer message.
AMQP.Basic.Get	direct access to a queue.
AMQP.Basic.GetEmpty	indicate no messages available.
AMQP.Basic.GetOk	provide client with a message.
AMQP.Basic.Publish	publish a message.
AMQP.Basic.Qos	specify quality of service.
AMQP.Basic.QosOk	confirm the requested qos.
AMQP.Basic.Recover	redeliver unacknowledged messages.
AMQP.Basic.Reject	reject an incoming message.
AMQP.Basic.Return	return a failed message.
AMQP.Channel.Alert	send a non-fatal warning message.
AMQP.Channel.Close	request a channel close.
AMQP.Channel.CloseOk	confirm a channel close.
AMQP.Channel.Flow	enable/disable flow from peer.
AMQP.Channel.FlowOk	confirm a flow method.
AMQP.Channel.Open	open a channel for use.
AMQP.Channel.OpenOk	signal that the channel is ready.
AMQP.Connection.Close	request a connection close.
AMQP.Connection.CloseOk	confirm a connection close.
AMQP.Connection.Open	open connection to virtual host.
AMQP.Connection.OpenOk	signal that the connection is ready.
AMQP.Connection.Redirect	asks the client to use a different server.
AMQP.Connection.Secure	security mechanism challenge.
AMQP.Connection.SecureOk	security mechanism response.
AMQP.Connection.Start	start connection negotiation.
AMQP.Connection.StartOk	select security mechanism and locale.
AMQP.Connection.Tune	propose connection tuning parameters.
AMQP.Connection.TuneOk	negotiate connection tuning parameters.
AMQP.Dtx.Select	select standard transaction mode.
AMQP.Dtx.SelectOk	confirm transaction mode.
AMQP.Dtx.Start	start a new distributed transaction.
AMQP.Dtx.StartOk	confirm the start of a new distributed transaction.
AMQP.Exchange.Declare	declare exchange, create if needed.
AMQP.Exchange.DeclareOk	confirms an exchange declaration.
AMQP.Exchange.Delete	delete an exchange.
AMQP.Exchange.DeleteOk	confirm deletion of an exchange.
AMQP.File.Ack	acknowledge one or more messages.
AMQP.File.Cancel	end a queue consumer.
AMQP.File.CancelOk	confirm a cancelled consumer.
AMQP.File.Consume	start a queue consumer.
AMQP.File.ConsumeOk	confirm a new consumer.
AMQP.File.Deliver	notify the client of a consumer message.
AMQP.File.Open	request to start staging.
AMQP.File.OpenOk	confirm staging ready.
AMQP.File.Publish	publish a message.
AMQP.File.Qos	specify quality of service.
AMQP.File.QosOk	confirm the requested qos.
AMQP.File.Reject	reject an incoming message.
AMQP.File.Return	return a failed message.
AMQP.File.Stage	stage message content.
AMQP.Queue.Bind	bind queue to an exchange.
AMQP.Queue.BindOk	confirm bind successful.
AMQP.Queue.Declare	declare queue, create if needed.
AMQP.Queue.DeclareOk	confirms a queue definition.
AMQP.Queue.Delete	delete a queue.
AMQP.Queue.DeleteOk	confirm deletion of a queue.
AMQP.Queue.Purge	purge a queue.
AMQP.Queue.PurgeOk	confirms a queue purge.
AMQP.Stream.Cancel	end a queue consumer.
AMQP.Stream.CancelOk	confirm a cancelled consumer.
AMQP.Stream.Consume	start a queue consumer.
AMQP.Stream.ConsumeOk	confirm a new consumer.
AMQP.Stream.Deliver	notify the client of a consumer message.
AMQP.Stream.Publish	publish a message.
AMQP.Stream.Qos	specify quality of service.
AMQP.Stream.QosOk	confirm the requested qos.
AMQP.Stream.Return	return a failed message.
AMQP.Test.Content	test content handling.
AMQP.Test.ContentOk	report content test result.
AMQP.Test.Integer	test integer handling.
AMQP.Test.IntegerOk	report integer test result.
AMQP.Test.String	test string handling.
AMQP.Test.StringOk	report string test result.
AMQP.Test.Table	test field table handling.
AMQP.Test.TableOk	report table test result.
AMQP.Tunnel.Request	sends a tunnelled method.
AMQP.Tx.Commit	commit the current transaction.
AMQP.Tx.CommitOk	confirm a successful commit.
AMQP.Tx.Rollback	abandon the current transaction.
AMQP.Tx.RollbackOk	confirm a successful rollback.
AMQP.Tx.Select	select standard transaction mode.
AMQP.Tx.SelectOk	confirm transaction mode.
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.
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.
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.

Class Summary

Address	A representation of network addresses, i.e.
AMQP.Access
AMQP.Basic
AMQP.BasicProperties	.
AMQP.Channel
AMQP.Connection
AMQP.Dtx
AMQP.Exchange
AMQP.File
AMQP.FileProperties	.
AMQP.PROTOCOL
AMQP.Queue
AMQP.Stream
AMQP.StreamProperties	.
AMQP.Test
AMQP.TestProperties	.
AMQP.Tunnel
AMQP.TunnelProperties	.
AMQP.Tx
ConnectionFactory	Convenience "factory" class to facilitate opening a Connection to an AMQP broker.
ConnectionParameters	Properties bean to encapsulate parameters for a Connection.
DefaultConsumer	Convenience class providing a default implementation of Consumer.
Envelope	Encapsulates a group of parameters used for AMQP's Basic methods
GetResponse	Encapsulates the response from a Channel.basicGet(int, java.lang.String, boolean) message-retrieval method call - essentially a static bean "holder" with message response data.
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

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.
RedirectException	Encapsulates an exception requiring redirection to the next from a list of "known addresses"
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.