Uses of Package
com.rabbitmq.client
Package
Description
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
Implementations of interfaces specified in the client API, and their supporting classes.
NIO network connector.
Implementation of connection and topology recovery.
JSON-RPC client and server classes for supporting JSON-RPC over an AMQP transport.
-
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.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.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
Connection
to a RabbitMQ node.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.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.An object providing access to a LongString.Public interface to objects representing an AMQP 0-9-1 methodInterface to gather execution data of the client.Thrown when the likely cause is an authentication failure.Provides a way to register (network, AMQP 0-9-1) connection recovery callbacks.A RecoveryDelayHandler is used to tell automatic recovery how long to sleep between reconnect attempts.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.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.A factory to createSSLContext
s.Indicates an exception thrown during topology recovery.Contract to log outbound and inboundCommand
s.Implement this interface in order to be notified of connection unblock events. -
ClassDescriptionA representation of network addresses, i.e. host/port pairs, with some utility functions for parsing address strings.Thrown when application tries to perform an action on connection/channel which was already closedImplement 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.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.Callback interface to be notified when a message is delivered.Interface to an exception-handling object.Encapsulates the response from a
Channel.basicGet(java.lang.String, boolean)
message-retrieval method call - essentially a static bean "holder" with message response data.An object providing access to a LongString.Public interface to objects representing an AMQP 0-9-1 methodInterface to gather execution data of the client.A RecoveryDelayHandler is used to tell automatic recovery how long to sleep between reconnect attempts.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.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.A factory to createSSLContext
s.Indicates an exception thrown during topology recovery.Contract to log outbound and inboundCommand
s.Implement this interface in order to be notified of connection unblock events. -
ClassDescriptionA representation of network addresses, i.e. host/port pairs, with some utility functions for parsing address strings.A factory to create
SSLContext
s. -
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.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.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.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.Callback interface to be notified when a message is delivered.Interface to an exception-handling object.Encapsulates the response from a
Channel.basicGet(java.lang.String, boolean)
message-retrieval method call - essentially a static bean "holder" with message response data.Public interface to objects representing an AMQP 0-9-1 methodInterface to gather execution data of the client.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 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.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.Implement this interface in order to be notified of connection unblock events. -
ClassDescriptionInterface for application callback objects to receive notifications and messages from a queue by subscription.Encapsulates the response from a
Channel.basicGet(java.lang.String, boolean)
message-retrieval method call - essentially a static bean "holder" with message response data. -
ClassDescriptionInterface to a channel.Convenience class which manages simple RPC-style communication.Holder class to configure a
RpcClient
.Class which manages a request queue for a simple RPC-style service.Subclass of RpcServer which accepts UTF-8 string requests.