Uses of Package
com.rabbitmq.client
-
Packages that use com.rabbitmq.client Package Description com.rabbitmq.client The client API proper: classes and interfaces representing the AMQP connections, channels, and wire-protocol framing descriptors.com.rabbitmq.client.impl Implementations of interfaces specified in the client API, and their supporting classes.com.rabbitmq.client.impl.nio NIO network connector.com.rabbitmq.client.impl.recovery Implementation of connection and topology recovery.com.rabbitmq.tools.jsonrpc JSON-RPC client and server classes for supporting JSON-RPC over an AMQP transport. -
Classes in com.rabbitmq.client used by com.rabbitmq.client.impl Class Description Address A representation of network addresses, i.e.AlreadyClosedException Thrown when application tries to perform an action on connection/channel which was already closedAMQP 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.BasicProperties 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.Blocked 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.Connection.Unblocked AMQP.Connection.UpdateSecret AMQP.Connection.UpdateSecretOk 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 BlockedCallback Implement this interface in order to be notified of connection block events.BlockedListener Implement this interface in order to be notified of connection block and unblock events.BuiltinExchangeType Enum for built-in exchange types.CancelCallback Callback interface to be notified of the cancellation of a consumer.Channel Interface to a channel.ChannelContinuationTimeoutException Exception thrown when a channel times out on a continuation during a RPC call.Command Interface to a container for an AMQP method-and-arguments, with optional content header and body.ConfirmCallback Implement this interface in order to be notified of Confirm events.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.ConsumerShutdownSignalCallback Callback interface to be notified when either the consumer channel or the underlying connection has been shut down.ContentHeader Public API for abstract AMQP content header objects.DeliverCallback Callback interface to be notified when a message is delivered.ExceptionHandler Interface to an exception-handling object.GetResponse Encapsulates the response from aChannel.basicGet(java.lang.String, boolean)message-retrieval method call - essentially a static bean "holder" with message response data.LongString An object providing access to a LongString.Method Public interface to objects representing an AMQP 0-9-1 methodMetricsCollector Interface to gather execution data of the client.RecoveryDelayHandler A RecoveryDelayHandler is used to tell automatic recovery how long to sleep between reconnect attempts.ReturnCallback Implement this interface in order to be notified of failed deliveries when basicPublish is called with "mandatory" or "immediate" flags set.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 signalsShutdownSignalException Encapsulates a shutdown condition for a connection to an AMQP broker.SocketConfigurator SslContextFactory A factory to createSSLContexts.TopologyRecoveryException Indicates an exception thrown during topology recovery.TrafficListener Contract to log outbound and inboundCommands.UnblockedCallback Implement this interface in order to be notified of connection unblock events. -
Classes in com.rabbitmq.client used by com.rabbitmq.client.impl.nio Class Description Address A representation of network addresses, i.e.SocketChannelConfigurator SslContextFactory A factory to createSSLContexts.SslEngineConfigurator -
Classes in com.rabbitmq.client used by com.rabbitmq.client.impl.recovery Class Description Address A representation of network addresses, i.e.AddressResolver Strategy interface to get the potential servers to connect to.AMQP.Basic.RecoverOk AMQP.BasicProperties AMQP.Confirm.SelectOk AMQP.Exchange.BindOk AMQP.Exchange.DeclareOk AMQP.Exchange.DeleteOk AMQP.Exchange.UnbindOk AMQP.Queue.BindOk AMQP.Queue.DeclareOk AMQP.Queue.DeleteOk AMQP.Queue.PurgeOk AMQP.Queue.UnbindOk AMQP.Tx.CommitOk AMQP.Tx.RollbackOk AMQP.Tx.SelectOk BlockedCallback Implement this interface in order to be notified of connection block events.BlockedListener Implement this interface in order to be notified of connection block and unblock events.BuiltinExchangeType Enum for built-in exchange types.CancelCallback Callback interface to be notified of the cancellation of a consumer.Channel Interface to a channel.Command Interface to a container for an AMQP method-and-arguments, with optional content header and body.ConfirmCallback Implement this interface in order to be notified of Confirm events.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.ConsumerShutdownSignalCallback Callback interface to be notified when either the consumer channel or the underlying connection has been shut down.DeliverCallback Callback interface to be notified when a message is delivered.ExceptionHandler Interface to an exception-handling object.GetResponse Encapsulates the response from aChannel.basicGet(java.lang.String, boolean)message-retrieval method call - essentially a static bean "holder" with message response data.Method Public interface to objects representing an AMQP 0-9-1 methodMetricsCollector Interface to gather execution data of the client.Recoverable Provides a way to register (network, AMQP 0-9-1) connection recovery callbacks.RecoverableChannel Convenient interface when working against auto-recovery channels.RecoverableConnection Convenient interface when working against auto-recovery connections.RecoveryListener A RecoveryListener receives notifications about completed automatic connection recovery.ReturnCallback Implement this interface in order to be notified of failed deliveries when basicPublish is called with "mandatory" or "immediate" flags set.ReturnListener Implement this interface in order to be notified of failed deliveries when basicPublish is called with "mandatory" or "immediate" flags set.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 signalsShutdownSignalException Encapsulates a shutdown condition for a connection to an AMQP broker.UnblockedCallback Implement this interface in order to be notified of connection unblock events. -
Classes in com.rabbitmq.client used by com.rabbitmq.tools.jsonrpc Class Description AMQP.BasicProperties Channel Interface to a channel.RpcClient Convenience class which manages simple RPC-style communication.RpcClientParams Holder class to configure aRpcClient.RpcServer Class which manages a request queue for a simple RPC-style service.StringRpcServer Subclass of RpcServer which accepts UTF-8 string requests.