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.
LongString	An object providing access to a LongString.

Class Summary

AMQChannel	Base class modelling an AMQ channel.
AMQChannel.BlockingRpcContinuation<T>
AMQChannel.SimpleBlockingRpcContinuation
AMQCommand
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	request an access ticket.
AMQImpl.Access.RequestOk	grant access to server resources.
AMQImpl.Basic
AMQImpl.Basic.Ack	acknowledge one or more messages.
AMQImpl.Basic.Cancel	end a queue consumer.
AMQImpl.Basic.CancelOk	confirm a cancelled consumer.
AMQImpl.Basic.Consume	start a queue consumer.
AMQImpl.Basic.ConsumeOk	confirm a new consumer.
AMQImpl.Basic.Deliver	notify the client of a consumer message.
AMQImpl.Basic.Get	direct access to a queue.
AMQImpl.Basic.GetEmpty	indicate no messages available.
AMQImpl.Basic.GetOk	provide client with a message.
AMQImpl.Basic.Publish	publish a message.
AMQImpl.Basic.Qos	specify quality of service.
AMQImpl.Basic.QosOk	confirm the requested qos.
AMQImpl.Basic.Recover	redeliver unacknowledged messages.
AMQImpl.Basic.Reject	reject an incoming message.
AMQImpl.Basic.Return	return a failed message.
AMQImpl.Channel
AMQImpl.Channel.Alert	send a non-fatal warning message.
AMQImpl.Channel.Close	request a channel close.
AMQImpl.Channel.CloseOk	confirm a channel close.
AMQImpl.Channel.Flow	enable/disable flow from peer.
AMQImpl.Channel.FlowOk	confirm a flow method.
AMQImpl.Channel.Open	open a channel for use.
AMQImpl.Channel.OpenOk	signal that the channel is ready.
AMQImpl.Connection
AMQImpl.Connection.Close	request a connection close.
AMQImpl.Connection.CloseOk	confirm a connection close.
AMQImpl.Connection.Open	open connection to virtual host.
AMQImpl.Connection.OpenOk	signal that the connection is ready.
AMQImpl.Connection.Redirect	asks the client to use a different server.
AMQImpl.Connection.Secure	security mechanism challenge.
AMQImpl.Connection.SecureOk	security mechanism response.
AMQImpl.Connection.Start	start connection negotiation.
AMQImpl.Connection.StartOk	select security mechanism and locale.
AMQImpl.Connection.Tune	propose connection tuning parameters.
AMQImpl.Connection.TuneOk	negotiate connection tuning parameters.
AMQImpl.DefaultMethodVisitor
AMQImpl.Dtx
AMQImpl.Dtx.Select	select standard transaction mode.
AMQImpl.Dtx.SelectOk	confirm transaction mode.
AMQImpl.Dtx.Start	start a new distributed transaction.
AMQImpl.Dtx.StartOk	confirm the start of a new distributed transaction.
AMQImpl.Exchange
AMQImpl.Exchange.Declare	declare exchange, create if needed.
AMQImpl.Exchange.DeclareOk	confirms an exchange declaration.
AMQImpl.Exchange.Delete	delete an exchange.
AMQImpl.Exchange.DeleteOk	confirm deletion of an exchange.
AMQImpl.File
AMQImpl.File.Ack	acknowledge one or more messages.
AMQImpl.File.Cancel	end a queue consumer.
AMQImpl.File.CancelOk	confirm a cancelled consumer.
AMQImpl.File.Consume	start a queue consumer.
AMQImpl.File.ConsumeOk	confirm a new consumer.
AMQImpl.File.Deliver	notify the client of a consumer message.
AMQImpl.File.Open	request to start staging.
AMQImpl.File.OpenOk	confirm staging ready.
AMQImpl.File.Publish	publish a message.
AMQImpl.File.Qos	specify quality of service.
AMQImpl.File.QosOk	confirm the requested qos.
AMQImpl.File.Reject	reject an incoming message.
AMQImpl.File.Return	return a failed message.
AMQImpl.File.Stage	stage message content.
AMQImpl.Queue
AMQImpl.Queue.Bind	bind queue to an exchange.
AMQImpl.Queue.BindOk	confirm bind successful.
AMQImpl.Queue.Declare	declare queue, create if needed.
AMQImpl.Queue.DeclareOk	confirms a queue definition.
AMQImpl.Queue.Delete	delete a queue.
AMQImpl.Queue.DeleteOk	confirm deletion of a queue.
AMQImpl.Queue.Purge	purge a queue.
AMQImpl.Queue.PurgeOk	confirms a queue purge.
AMQImpl.Stream
AMQImpl.Stream.Cancel	end a queue consumer.
AMQImpl.Stream.CancelOk	confirm a cancelled consumer.
AMQImpl.Stream.Consume	start a queue consumer.
AMQImpl.Stream.ConsumeOk	confirm a new consumer.
AMQImpl.Stream.Deliver	notify the client of a consumer message.
AMQImpl.Stream.Publish	publish a message.
AMQImpl.Stream.Qos	specify quality of service.
AMQImpl.Stream.QosOk	confirm the requested qos.
AMQImpl.Stream.Return	return a failed message.
AMQImpl.Test
AMQImpl.Test.Content	test content handling.
AMQImpl.Test.ContentOk	report content test result.
AMQImpl.Test.Integer	test integer handling.
AMQImpl.Test.IntegerOk	report integer test result.
AMQImpl.Test.String	test string handling.
AMQImpl.Test.StringOk	report string test result.
AMQImpl.Test.Table	test field table handling.
AMQImpl.Test.TableOk	report table test result.
AMQImpl.Tunnel
AMQImpl.Tunnel.Request	sends a tunnelled method.
AMQImpl.Tx
AMQImpl.Tx.Commit	commit the current transaction.
AMQImpl.Tx.CommitOk	confirm a successful commit.
AMQImpl.Tx.Rollback	abandon the current transaction.
AMQImpl.Tx.RollbackOk	confirm a successful rollback.
AMQImpl.Tx.Select	select standard transaction mode.
AMQImpl.Tx.SelectOk	confirm transaction mode.
ChannelManager	Manages a set of channels, indexed by channel number.
ChannelN	Main interface to AMQP protocol functionality.
ContentHeaderPropertyReader	Parses an AMQP wire-protocol ContentHeader from a DataInputStream.
ContentHeaderPropertyWriter	Generates an AMQP wire-protocol packet from a ContentHeader.
DefaultExceptionHandler
Frame	Represents an AMQP wire-protocol frame, with frame type, channel number, and payload bytes.
LongStringHelper	Utility for working with LongStringHelper.ByteArrayLongStrings.
LongStringHelper.ByteArrayLongString	Private API - Implementation of LongString.
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.
SocketFrameHandler	A socket-based frame handler.
TruncatedInputStream	Utility stream: proxies another stream, making it appear to be no longer than a preset limit.
Version	Encapsulation of AMQP protocol version

Package com.rabbitmq.client.impl Description

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