Package com.rabbitmq.client
package com.rabbitmq.client
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
-
ClassDescriptionA representation of network addresses, i.e. host/port pairs, with some utility functions for parsing address strings.Strategy interface to get the potential servers to connect to.Thrown when application tries to perform an action on connection/channel which was already closedThrown when the broker refuses access due to an authentication failure.Implement this interface in order to be notified of connection block events.Implement this interface in order to be notified of connection block and unblock events.Enum for built-in exchange types.Callback interface to be notified of the cancellation of a consumer.Interface to a channel.Exception thrown when a channel times out on a continuation during a RPC call.Interface to a container for an AMQP method-and-arguments, with optional content header and body.Implement this interface in order to be notified of Confirm events.Implement this interface in order to be notified of Confirm events.Public API: Interface to an AMQ connection.Convenience factory class to facilitate opening a
Connectionto a RabbitMQ node.Helper class to loadConnectionFactorysettings from a property file.Interface for application callback objects to receive notifications and messages from a queue by subscription.Callback interface to be notified when either the consumer channel or the underlying connection has been shut down.Public API for abstract AMQP content header objects.Convenience class providing a default implementation ofConsumer.Default SASL configuration.Callback interface to be notified when a message is delivered.Encapsulates an arbitrary message - simple "bean" holder structure.AddressResolverthat resolves DNS record IPs.AddressResolverthat resolves addresses against a DNS SRV request.Encapsulates a group of parameters used for AMQP's Basic methodsInterface to an exception-handling object.Encapsulates the response from aChannel.basicGet(java.lang.String, boolean)message-retrieval method call - essentially a static bean "holder" with message response data.Implementation of SaslConfig that uses the JDK SASL implementation.Simple implementation ofAddressResolverthat returns a fixed list.An object providing access to a LongString.Encapsulates a frame format error at the wire level.Subclass of RpcServer which uses AMQP wire-format encoded tables as requests and replies.Constant holder class with useful static instances ofAMQContentHeader.Public interface to objects representing an AMQP 0-9-1 methodInterface to gather execution data of the client.Encapsulates an exception indicating that the connection has missed too many heartbeats and is being shut down.Thrown when the likely cause is an authentication failure.Thrown to indicate that the server does not support the wire protocol version we requested immediately after opening the TCP socket.Provides a way to register (network, AMQP 0-9-1) connection recovery callbacks.Convenient interface when working against auto-recovery channels.Convenient interface when working against auto-recovery connections.A RecoveryDelayHandler is used to tell automatic recovery how long to sleep between reconnect attempts.Basic implementation ofRecoveryDelayHandlerthat returns thenetwork recovery intervaleach time.Backoff implementation ofRecoveryDelayHandlerthat uses the Fibonacci sequence (by default) to increase the recovery delay time after each failed attempt.A RecoveryListener receives notifications about completed automatic connection recovery.Implement this interface in order to be notified of failed deliveries when basicPublish is called with "mandatory" or "immediate" flags set.Implement this interface in order to be notified of failed deliveries when basicPublish is called with "mandatory" or "immediate" flags set.Convenience class which manages simple RPC-style communication.The response object is an envelope that contains all of the data provided to the `handleDelivery` consumerHolder class to configure aRpcClient.Class which manages a request queue for a simple RPC-style service.This interface represents a hook to allow you to control how exactly a sasl client is selected during authentication.Our own view of a SASL authentication mechanism, introduced to remove a dependency on javax.security.sasl.A ShutdownListener receives information about the shutdown of connections and channels.Interface for components that are shutdown capable and that allow listeners to be added for shutdown signalsEncapsulates a shutdown condition for a connection to an AMQP broker.Ready-to-use instances and builder forSocketChannelConfigurator.Ready-to-use instances and builder forSocketConfigurator.A factory to createSSLContexts.Ready-to-use instances and builder forSslEngineConfigurators.Subclass of RpcServer which accepts UTF-8 string requests.Indicates an exception thrown during topology recovery.Contract to log outbound and inboundCommands.Convenience class providing a default implementation ofX509TrustManager.Implement this interface in order to be notified of connection unblock events.Thrown when the command parser hits an unexpected frame type.Indicates that aMethodobject was supplied that was not expected.Thrown when the protocol handlers detect an unknown class number or method number.Exception thrown when a RPC request isn't routed to any queue.